Java线程池同步

Question

我想执行以下算法 - 这必须在 Java 中完成

for(int i = 0; i< 100; i++){
    create 8 threads which perform a task
    wait for all threads to finish
}

由于开销(以及每个线程的工作时间小于 20 毫秒的事实)，最好不要连续创建和销毁线程，这带来了线程池的想法 1 .我也知道使用可执行文件 2 ，可以调用 shutdown，然后调用 awaitTermination。然而，由于循环，在这种情况下是不可取的。那么如何实现线程同步呢？

我想像使用传统线程的 join() 方法那样同步线程池中的线程。

Answer 1

您是否尝试过查看 Cyclic Barrier .它经过优化，允许一组线程停止并等待，直到每个人都达到一个共同的障碍。我看不出有任何理由不能将它与已知数量的池化线程一起使用，并引用一个公共(public)屏障。如果您需要在达到障碍 await() 计数时调用的回调进行同步，则可能会有一些额外的复杂性，因为它在不同的线程中执行。