【并发技术15】线程同步工具CyclicBarrier的使用

一个同步辅助类，它允许一组线程互相等待，直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中，这些线程必须不时地互相等待，此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用，所以称它为循环 的 barrier。

CyclicBarrier 可以使不同的线程彼此等待，在不同的线程都执行完了后，再执行下面的程序。比如A、B、C三个同学要去玩，大巴在校门口，A、B、C分别从各自的寝室出来，先后到达大巴处，先来的必须等待，直到三个同学都来了，大巴才能走。他们要玩两个地方M和N，到了M处，三个同学又各自去玩了，玩完后各自回到大巴上，先回来的必须等待，直到三个同学都到了，大巴才能到N处，这个大巴可以循环利用。这个大巴就是 CyclicBarrier。

public class CyclicBarrierTest {
    public static void main(String[] args) {
        ExecutorService service = Executors.newCachedThreadPool();
        final CyclicBarrier cb = new CyclicBarrier(3); //设置要三个线程等待，都执行完了再往下执行
        System.out.println("初始化：当前有" + (cb.getNumberWaiting() + "个线程在等待"));
         //3个任务
        for (int i = 0; i < 3; i++) {
            Runnable run = new Runnable() {  
                public void run() {  
                    try {  
                        Thread.sleep((long)(Math.random()*10000));  
                        System.out.println(Thread.currentThread().getName() 
                                + "即将到达集合点1，当前已有" + (cb.getNumberWaiting()+1) + "个线程到达，"
                                + (cb.getNumberWaiting()==2?"都到齐了，去集合点2！":"正在等候……"));  
                        // 访问完后，释放 ，如果屏蔽下面的语句，则在控制台只能打印3条记录，之后线程一直阻塞
                        cb.await(); //等待 
                        Thread.sleep((long)(Math.random()*10000));  
                        System.out.println(Thread.currentThread().getName() 
                                + "即将到达集合点2，当前已有" + (cb.getNumberWaiting()+1) + "个线程到达，"
                                + (cb.getNumberWaiting()==2?"都到齐了，去集合点3！":"正在等候……"));   
                        cb.await();
                        Thread.sleep((long)(Math.random()*10000));  
                        System.out.println(Thread.currentThread().getName() 
                                + "即将到达集合点3，当前已有" + (cb.getNumberWaiting()+1) + "个线程到达，"
                                + (cb.getNumberWaiting()==2?"都到齐了，执行完毕！":"正在等候……"));  
                        cb.await();
                    } catch (Exception e) {  
                    }  
                }  
            };  
            service.execute(run);  //执行任务
        }  
        service.shutdown(); //关闭线程
    }
}

初始化：当前有0个线程在等待
pool-1-thread-3即将到达集合点1，当前已有1个线程到达，正在等候……
pool-1-thread-2即将到达集合点1，当前已有2个线程到达，正在等候……
pool-1-thread-1即将到达集合点1，当前已有3个线程到达，都到齐了，去集合点2！
pool-1-thread-2即将到达集合点2，当前已有1个线程到达，正在等候……
pool-1-thread-3即将到达集合点2，当前已有2个线程到达，正在等候……
pool-1-thread-1即将到达集合点2，当前已有3个线程到达，都到齐了，去集合点3！
pool-1-thread-3即将到达集合点3，当前已有1个线程到达，正在等候……
pool-1-thread-1即将到达集合点3，当前已有2个线程到达，正在等候……
pool-1-thread-2即将到达集合点3，当前已有3个线程到达，都到齐了，执行完毕！