ForkJoinpool::关闭vs ForkJoinpool::关闭现在在ForkJoinpool::加入之后

Question

代码：

            final ForkJoinPool forkJoinPool = new ForkJoinPool(PARALLELISM_NUMBER);
            try {
                final List<Record> records = getRecrods();
                List<List<Record>> partitionRecordLists = Lists.partition(records, BATCH_SIZE);

                forkJoinPool.submit(() ->
                        partitionRecordLists.parallelStream().forEach(this::performSomething)
                ).join();
                
            } finally {
                forkJoinPool.shutdown();
            }

我有上面的代码来并行执行一些任务。考虑到join已经让调用线程等待完成，不知道它是否应该是shoutdownow（）而不是finally块中的shoutdown（）。

注意：performSomething仅从输入列表中读取。

Answer 1

通常：shutdown（）表示您正在为executor服务执行干净/有序的关机操作，Shutdownow（） 用于特定情况-通常用于错误处理或绕过任何未启动且不太重要的后台服务。

在您的情况下，使用join（）不会有任何区别。然而，考虑另一个维护代码的人： Cube（）/代码>在代码块内部是不太明显的，因此他们会发现看到<代码> FokCuangCube感到奇怪。关闭现在（） 在结尾处没有注释来解释为什么这是可以的，而 shutdown（）是更明显的更简洁的方式来指示池结束处理已经完成。

final ForkJoinPool forkJoinPool = new ForkJoinPool(...);
try {
    // Long block:
    // harder to spot join() here whereas shutdown() stands out
} finally {
    forkJoinPool.shutdown();
}