java并发编程包JUC线程同步CyclicBarrier语法示例

CyclicBarrier barrier = new CyclicBarrier(2);

Runnable      barrierAction =   创建线程;
CyclicBarrier barrier  = new CyclicBarrier(2, barrierAction);

Runnable barrier1Action = new Runnable() {
    public void run() {
        System.out.println("障碍1集合成功了，所有人都到了景点门口 ");
    }
};
Runnable barrier2Action = new Runnable() {
    public void run() {
        System.out.println("障碍2集合成功了，所有人都到了山顶");
    }
};
//障碍1 景点门口
CyclicBarrier barrier1 = new CyclicBarrier(2, barrier1Action);
//障碍2 山顶
CyclicBarrier barrier2 = new CyclicBarrier(2, barrier2Action);

//旅游计划，阶段目标一：景点门口集合
CyclicBarrierRunnable barrierRunnable1 =
        new CyclicBarrierRunnable(barrier1, barrier2);
//旅游计划，阶段目标二：爬山到山顶集合
CyclicBarrierRunnable barrierRunnable2 =
        new CyclicBarrierRunnable(barrier1, barrier2);
new Thread(barrierRunnable1).start();  //游客A，Thread-0
new Thread(barrierRunnable2).start();  //游客B，Thread-1

public class CyclicBarrierRunnable implements Runnable{
    CyclicBarrier barrier1 = null;  //障碍1
    CyclicBarrier barrier2 = null;  //障碍2
    public CyclicBarrierRunnable( CyclicBarrier barrier1,CyclicBarrier barrier2) {
        this.barrier1 = barrier1;
        this.barrier2 = barrier2;
    }
    public void run() {
        try {
            Thread.sleep(1000);  //这里写出发去景点的过程代码
            System.out.println(Thread.currentThread().getName() +
                                " 到达景点门口");
            this.barrier1.await();
            Thread.sleep(1000);  //这里写爬山的过程代码
            System.out.println(Thread.currentThread().getName() +
                                " 爬山爬到山顶");
            this.barrier2.await();
            System.out.println(Thread.currentThread().getName() +
                                " 玩的不错，下山回家!");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }
}