java - 执行器服务在未等待任务完成的情况下终止

Question

我有这样的执行者服务:

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模式下运行代码时，任务即将完成。当我正常运行它时，任务未完成，线程正在终止。线程不是会等待所有任务完成吗？为什么他们没有完成任务就被解雇？

Answer 1

尝试

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