java CyclicBarrier

Barrier和CountDownLatch有些类似，它能阻塞一组线程直到某个事件发生，但是Barrier阻塞的这组线程必须同时到达栅栏位置，才能继续执行。闭锁用于等待事件，而栅栏用于等待同组的其他线程。对应构造方法：CyclicBarrier(int parties)。parties对应阻塞的线程数量。

Barrier还允许在所有线程都到达栅栏位置时，启动另外一个线程执行某些事情，等到这个线程执行完毕后栅栏中的线程才可以被释放。这个对应构造方法CyclicBarrier(int parties, Runnable barrierAction)中的barrierAction动作。

Barrier和CountDownLatch另一个不同之处是Barrier是可重用的，可是使用reset方法重置到初始状态。

在某些时候Barrier是可以替代CountDownLatch的，例如在之前的例子中有一个开始门（控制多个线程同时开始）和一个结束门（等待多个线程都结束），那么结束门可以作为barrierAction，然后完全可以用Barrier代替。

1.我们首先考虑两个例子：

1.五个人约好了在某个公园集合然后一起去放风筝，那么所有的人从不同的地方赶来赴约，显然他们不可能是同时达到集合地点，那么早到的人必须等待还没到人直到所有人都到齐才能进行下一步活动。

这个是使用CyclicBarrier(int parties)的例子。

2.在一个建筑工地上准备盖一个厕所，首先包工头安排任务，一个人负责准备砖头，一个负责准备水泥，还有一个准备沙子。这些材料必须全部齐全以后才能进行下一步工作，那么先准备好的人必须等待。等材料都准备好之后一台搅拌机将沙子和水泥搅拌均匀，之后三个人开始每个人各盖一堵墙。

这个是使用CyclicBarrier(int parties, Runnable barrierAction)的例子。

2.来实现工地的例子

public class BarrierExample {
private CyclicBarrier barrier;
public BarrierExample() {
barrier = new CyclicBarrier(3, new Runnable() {
public void run() {
for (int i = 0; i < 3; i++) {
System.out.println("搅拌机在搅拌");
Thread.yield();
}
}
});
}

public void start(){
new Thread(new Builder(),"搬砖工人").start();
new Thread(new Builder(),"运沙工人").start();
new Thread(new Builder(),"搬水泥工人").start();
}

private class Builder implements Runnable {
@Override
public void run() {
for (int i = 0; i < 3; i++) {
System.out.println(Thread.currentThread().getName() + "我正在路上");
Thread.yield();
}
try {
barrier.await();
} catch (InterruptedException | BrokenBarrierException e) {
return;
}
for(int i = 0; i < 3; i++){
System.out.println(Thread.currentThread().getName() + "我在垒墙");
Thread.yield();
}
}
}

public static void main(String[] args){
BarrierExample example = new  BarrierExample();
example.start();
}
}
result:
运沙工人我正在路上
搬砖工人我正在路上
搬砖工人我正在路上
搬砖工人我正在路上
搬水泥工人我正在路上
运沙工人我正在路上
搬水泥工人我正在路上
运沙工人我正在路上
搬水泥工人我正在路上
搅拌机在搅拌
搅拌机在搅拌
搅拌机在搅拌
搬水泥工人我在垒墙
搬砖工人我在垒墙
搬水泥工人我在垒墙
运沙工人我在垒墙
搬水泥工人我在垒墙
搬砖工人我在垒墙
搬砖工人我在垒墙
运沙工人我在垒墙
运沙工人我在垒墙