CyclicBarrier学习

Posted 2022-12-13 彭薄

  多了解Concurrent包里面的类对提高并发开发很有帮助。下面就一个实例学习一下CycleBarrier的使用方法：

　　CyclicBarrier有两个构造函数:

　　　　CyclicBarrier(int parties); int类型的参数表示有几个线程来参与这个屏障拦截;

　　　　CyclicBarrier(int parties,Runnable barrierAction);当所有线程到达一个屏障点时,优先执行            barrierAction这个线程.

 * 原理：
 * CyclicBarrier中有一个计数器，每当一个线程调用await()方法时计数器就会减1
 * 计数器不等于0时，会通过ReentrantLock重入所的condition的await()方法将线程阻塞
 * 直到计数器等于0时，会检测是否有barrierAction，如果有则执行barrierAction的run方法，然后唤醒signalAll()所有阻塞线程
 * 如果没有barrierAction则直接通过signalAll()唤醒所有阻塞线程

CycliBarrier和CountDownLatch的区别 

CycliBarrier和CountDownLatch都可以用来控制并发执行的流程，保证所有线程都做完自己的工作后在继续一些共性的工作。 
1.CycliBarrier可以重复利用，但是CountDownLatch不可以重复利用。 
2.CountDownLatch中计数值的递减需要自己手动去触发，但是CycliBarrier中计数值的减小是自动减小的。