如上代码创建了一个CyclicBarrier对象，其第一个参数为计数器初始值，第二个数Runable是当计数值为0时需要执行的任务。在main函数里面首先创建了一个大小为2的线程池。然后添加两个子任务到线程池，每个子任务在执行完自己的逻辑后会调用方法。一开始计数器值为2，当第一个线程调用await方法时，计数器值会递减为1，由于此时计数器值不为0，所以当前线程就到了屏障点而被阻塞。然后第二个线程调用await时，会进入屏障，计数器值也会递减，现在计数器值为0，这时就会去执行 CyclicBarrier构造函数中的任务，执行完毕后退出屏障点，并且唤醒被阻塞的第二个线程。这时候第一个线程也会退出屏障点继续向下运行。
上面的例子说明了多个线程之间是相互等待的，假如计数器值为N，那么随后调用 await 方法的N1个线程都会因为到达屏障点而被阻塞，当第N个线程调用await后，计数器值为0了，这时候第N个线程才会发出通知唤醒前面的N1个线程。也就是当全部线程都到达屏障点时才能一块继续向下执行。对于这个例子来说，使用CountDownLatch也可以得到类似的输出结果。下面再举个例子来说明CyclicBarrier的可复用性。
假设一个任务由阶段1、阶段2和阶段3组成，每个线程要串行地执行阶段1、阶段2和阶段3，当多个线程执行该任务时，必须要保证所有线程的阶段1全部完成后才能进入阶段2执行，当所有线程的阶段2全部完成后才能进入阶段3执行。下面使用 CyclicBarrier 来完成这个需求。
如上代码中，每个子线程在执行完阶段1后都调用了await方法，等到所有线程都到达屏障点后才会一块往下执行，这就保证了所有线程都完成了阶段1后才会开始执行阶段2。
到此这篇关于Java并发编程回环屏障CyclicBarrier的文章就介绍到这了,更多相关Java 回环屏障CyclicBarrier内容请搜索七叶笔记以前的文章或继续浏览下面的相关文章希望大家以后多多支持七叶笔记！
