我有这样的执行者服务:
ExecutorService exec = Executors.newFixedThreadPool(4);
for(int i=0; i<4;i++) {
Consumer consumer = new Consumer();
exec.execute(new ConsumerstartUpThread(consumer));
}
ConsumerStartUpThread 实现了 runnable，它的 run 方法具有巨大的功能，需要调用其他几个 API。现在，当我在 Debug模式下运行代码时，任务即将完成。当我正常运行它时，任务未完成，线程正在终止。线程不是会等待所有任务完成吗？为什么他们没有完成任务就被解雇？
最佳答案
尝试
ExecutorService exec = Executors.newFixedThreadPool(4);
List<Callable<Object>> tasks = new ArrayList<Callable<Object>>();
for (int i = 0; i < 4; i++) {
tasks.add(Executors.callable(new ConsumerstartUpThread(new Consumer())));
}
exec.invokeAll(tasks);
exec.shutdown();
invokeAll 将等待所有任务终止(请参阅 API)。为了更简单，让 ConsumerstartUpThread 实现 Callable 而不是 Runnable
关于java - 执行器服务在未等待任务完成的情况下终止，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/14868743/