CyclicBarrier(屏障拦截)
让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续运行。
CyclicBarrier
默认的构造方法是CyclicBarrier(int parties)
,其参数表示屏障拦截的线程数量,每个线程调用await方法告CyclicBarrier我已经到达了屏障,然后当前线程被阻塞。
CyclicBarrier
还提供一个更高级的构造函数CyclicBarrier(int parties,Runnable barrier- Action)
,用于在线程到达屏障时,优先执行barrierAction
,方便处理更复杂的业务场景
与CountDownLatch异同
CyclicBarrier
的计数器可以使用reset()
方法重置。所以CyclicBarrier
能处理更为复杂的业务场景。例如,如果计算发生错误,可以重置计数器,并让线程重新执行一次。
CyclicBarrier 加计数方式 计数达到指定值时释放所有等待线程 计数达到指定值时,计数置为0重新开始 调用await()方法计数加1,若加1后的值不等于构造方法的值,则线程阻塞 不可重复利用
CountDownLatch(数量执行)
CountDownLatch
允许一个或多个线程等待其他线程完成操作。假如有这样一个需求:我们需要解析一个Excel里多个sheet的数据,此时可以考虑使用多线程,每个线程解析一个sheet里的数据,等到所有的sheet都解析完之后,程序需要提示解析完成。在这个需求中,要实现主线程等待所有线程完成sheet的解析操作,最简单的做法是使用
join()方法
与CyclicBarrier异同
CountDownLatch
的计数器只能使用一次
CountDownLatch 减计数方式 计算为0时释放所有等待的线程 计数为0时,无法重置 调用countDown()方法计数减一,调用await()方法只进行阻塞,对计数没任何影响 不可重复利用
Sempahore(信号量)
信号量是用来控制同时访问特定资源的线程数量,它通过协调各个线程,以保证合理的使用公共资源