具有 Callable Future 的简单程序永远不会终止

Question

我在玩 Callable 和 Future 时偶然发现了一个问题。

这是一段永远不会终止和超时的代码，即使 IDE 允许运行 5 秒，并且代码不需要超过 3 秒（它给出了 Time Limit Exceeded 错误）：https://ideone.com/NcL0YV

/* package whatever; // don't place package name! */

import java.util.*;
import java.util.concurrent.*;
import java.lang.*;
import java.io.*;

/* Name of the class has to be "Main" only if the class is public. */
class Ideone
{
    public static void main (String[] args) throws java.lang.Exception
    {
        Ideone obj = new Ideone();
        Future<Integer> res = obj.doCallable();
        System.out.println(res.get());
    }
    public Future<Integer> calculate(Integer input) {
        ExecutorService executor = Executors.newFixedThreadPool(1);
        return executor.submit(() -> {
            long start = System.currentTimeMillis();
            Thread.sleep(2000);
            System.out.println("Sleep time in ms = "+(System.currentTimeMillis()-start));
            return input * input;
        });
    }
    public Future<Integer> doCallable() {
        int value = 99;
        try {
            Callable<Future> callable = () -> calculate(value);
            Future<Integer> future = callable.call();
            return future;
        } catch (final Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
}

这是一段类似的代码，因为我添加了“System.exit(0)”而终止（这是不可取的）：https://ideone.com/HDvl7y

/* package whatever; // don't place package name! */

import java.util.*;
import java.util.concurrent.*;
import java.lang.*;
import java.io.*;

/* Name of the class has to be "Main" only if the class is public. */
class Ideone
{
    public static void main (String[] args) throws java.lang.Exception
    {
        Ideone obj = new Ideone();
        Future<Integer> res = obj.doCallable();
        System.out.println(res.get());
        System.exit(0);
    }
    public Future<Integer> calculate(Integer input) {
        ExecutorService executor = Executors.newFixedThreadPool(1);
        return executor.submit(() -> {
            long start = System.currentTimeMillis();
            Thread.sleep(2000);
            System.out.println("Sleep time in ms = "+(System.currentTimeMillis()-start));
            return input * input;
        });
    }
    public Future<Integer> doCallable() {
        int value = 99;
        try {
            Callable<Future> callable = () -> calculate(value);
            Future<Integer> future = callable.call();
            return future;
        } catch (final Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
}

请帮助我理解为什么我们需要 System.exit(0) 或 shutdown() 即使可调用任务已完成（future.get() 调用是阻塞调用）。

编辑： 由于下面的代码 sn-p，我做了以上所有操作来解决我的应用程序中线程不断增加的主要问题。我不确定如何在不涉及主线程（立即退出）的情况​​下在某个超时后自动完成这个未来。

@Override
public void publish(@NonNull final String message,
                    @NonNull final String topicArn) throws PublishingException {
    if (!publishAsync(message, topicArn)) {
        throw new PublishingException("Publish attempt failed for the message:"
                + message);
    }
}

private boolean publishAsync(final String message,
                             final String topicArn) {
    Callable<Future> publishCallable = () -> snsClient.publishAsync(topicArn, message);
    try {
        Future<PublishResult> result = publishCallable.call();
        log.debug("Asynchronously published message {} to SNS topic {}.", message, topicArn);
        return !result.isDone() || result.get().getMessageId() != null;
    } catch (final Exception e) {
        return false;
    }
}

Answer 1

void shutdown()

启动有序关闭，其中执行先前提交的任务，但不会接受新任务。如果已经关闭，则调用不会产生额外的影响。

此方法不等待先前提交的任务完成执行。使用 awaitTermination 来做到这一点。