CyclicBarrier类简介

CyclicBarrier是回环屏障的意思，它可以让一组线程全部达到一个状态后再全部同时执行。

• 回环的意思

所有等待线程执行完毕，并重置CyclicBarrier的状态后它可被重用。

• 屏障的意思

线程调用await方法后就会被阻塞，这个阻塞点就称为屏障点，等所有线程都调用了await方法后，线程们就会冲破屏障，继续向下运行。

示例代码

应用场景一

一项任务被分解为两个子任务，由两个线程去执行子任务， 当两个线程把自己的任务都执行完毕后再对它们的结果进行汇总处理。

public class CyclicBarrierTest {
 static int[] task = {1,2,3,4,5,6,7,8};
 static int result1 = 0;
 static int result2 = 0;
 //创建一个CyclicBarrier的实例，添加一个所有子线程全部到达屏障后要执行的任务
 private static CyclicBarrier cyclicBarrier = new CyclicBarrier(2,new Runnable(){
 @Override
 public void run() {
 int sum = result1 +result2;
 System.out.println("最后合并后的结果等于:"+sum);
 }
 });
 public static void main(String[] args){
 Thread thread1 = new Thread(new Runnable(){
 @Override
 public void run() {
 try{
 System.out.println("线程1开始处理子任务...");
 int result = 0;
 for(int i=0;i<4;i++){
 result+=task[i];
 }
 result1= result;
 System.out.println("线程1任务处理完毕！处理结果："+result1);
 cyclicBarrier.await();
 }catch(Exception e){
 e.printStackTrace();
 }
 }
 });
 Thread thread2 = new Thread(new Runnable(){
 @Override
 public void run() {
 try{
 System.out.println("线程2开始处理子任务...");
 int result = 0;
 for(int i=4;i<8;i++){
 result+=task[i];
 }
 result2= result;
 System.out.println("线程2任务处理完毕！处理结果："+result2);
 cyclicBarrier.await();
 }catch(Exception e){
 e.printStackTrace();
 }
 }
 });
 thread1.start();
 thread2.start();
 }
	}

运行结果如下

应用场景二

假设一个任务由阶段 l、阶段 2 和阶段 3 组成，每个线程要串行地执行阶段 1、阶段 2 和阶段 3，当多个线程执行该任务时必须要保证所有线程的阶段 1全部完成后才 能进入阶段 2 执行， 当所有线程的阶段 2 全部完成后才能进入阶段 3 执行。

public class CyclicBarrierTest2 {
 //创建一个CyclicBarrier的实例，添加一个所有子线程全部到达屏障后要执行的任务
 private static CyclicBarrier cyclicBarrier = new CyclicBarrier(2);
 public static void main(String[] args){
 Thread thread1 = new Thread(new Runnable(){
 @Override
 public void run() {
 try{
 Thread.sleep(500);
 System.out.println("线程1完成第1阶段任务。");
 cyclicBarrier.await();
 Thread.sleep(1000);
 System.out.println("线程1完成第2阶段任务。");
 cyclicBarrier.await();
 Thread.sleep(1000);
 System.out.println("线程1完成第3阶段任务。");
 }catch(Exception e){
 e.printStackTrace();
 }
 }
 });
 Thread thread2 = new Thread(new Runnable(){
 @Override
 public void run() {
 try{
 Thread.sleep(1000);
 System.out.println("线程2完成第1阶段任务。");
 cyclicBarrier.await();
 Thread.sleep(500);
 System.out.println("线程2完成第2阶段任务。");
 cyclicBarrier.await();
 Thread.sleep(1000);
 System.out.println("线程2完成第3阶段任务。");
 }catch(Exception e){
 e.printStackTrace();
 }
 }
 });
 thread1.start();
 thread2.start();
 }
}

运行结果如下

在如上代码中，每个子线程在执行完阶段1后都调用了 await 方法， 等到所有线程都到达屏障点后才会一块往下执行，这就保证了所有线程都完成了阶段 l 后才会开始执行阶 段 2。然后在阶段 2 后面调用了 await 方法， 这保证了所有线程都完成了阶段 2 后， 才能 开始阶段 3 的执行。 这个功能使用单个 CountDownLatch 是无法完成的。