java-8 - 为什么 ExecutorService 不在流中工作？

Question

我正在通过流传递一组任务，这是一个简化的演示:

    ExecutorService executorService = Executors.newCachedThreadPool((r) -> {
        Thread thread = new Thread();
        thread.setDaemon(true); // even I removed this, it's still not working;
        return thread;
    });
    IntStream.range(0, TASK_COUNT).forEach(i -> {
        executorService.submit(() -> {
            out.println(i);
            return null;
        });
    });

在所有任务提交后，我尝试等待所有任务完成使用:

    executorService.shutdown();
    executorService.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);

但是输出是none，什么也没有打印出来。

有什么问题吗？任何帮助将不胜感激。

一个奇怪的发现是，当使用默认的DefaultThreadFactory 时，它是有效的。

ExecutorService executorService = Executors.newCachedThreadPool();

F.Y.I 守护进程线程是我已经检查过的原因。为了调试，我故意设置了它们。

Answer 1

您忘记将 Runnable 传递给 Thread 构造函数:

ExecutorService executorService = Executors.newCachedThreadPool(r -> {
    Thread thread = new Thread(r);
                               ^
    thread.setDaemon(false);
    return thread;
});