CountDownLatch:同步援助,允许一个或多个线程等待其他线程正在执行的一组操作完成。
CyclicBarrier:同步援助,让一组线程都等待对方达到一个共同的障碍点。
CountDownLatch 是计数器, 线程完成一个就记一个, 就像 报数一样, 只不过是递减的.
CyclicBarrier 线程之间会互相等待，每个线程在再到await方法地方都会阻塞，当所有的线程都执行await方法之后，就会释放阻塞
白话文
- await()
在所有参与者都已经在此 barrier 上调用 await 方法之前，将一直等待。
每个线程都互相等待，当有一个没有调用await的时候，所有的都等待.当所有线程都调用await方法后，就结束等待，之开始执行，当所有方法执行完毕之后，在执行构造中的run
public static void main(String[] args) throws InterruptedException {
ExecutorService exec = Executors.newCachedThreadPool();
final CyclicBarrier barrier = new CyclicBarrier(4, new Runnable() {
@Override
public void run() {
System.out.println("好了，大家可以去吃饭了……" );
}
});
System.out.println("要吃饭，必须所有人都到终点，oK?");
System.out.println("不放弃不抛弃！");
for (int i = 0; i < 4; i++) {
exec.execute(new Runnable() {
@Override
public void run() {
System.out
.println(Thread.currentThread().getName() + ":Go");
try {
Thread.sleep((long) (2000 * Math.random()));
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println(Thread.currentThread().getName()
+ ":我到终点了");
try {
// await()
// 在所有参与者都已经在此 barrier 上调用 await 方法之前，将一直等待。
barrier.await();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (BrokenBarrierException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()
+ ":终于可以吃饭啦！");
}
});
}
exec.shutdown();
}
要吃饭，必须所有人都到终点，oK?
不放弃不抛弃！
pool-1-thread-1:Go
pool-1-thread-2:Go
pool-1-thread-3:Go
pool-1-thread-4:Go
pool-1-thread-1:我到终点了
pool-1-thread-3:我到终点了
pool-1-thread-4:我到终点了
pool-1-thread-2:我到终点了
好了，大家可以去吃饭了……
pool-1-thread-2:终于可以吃饭啦！
pool-1-thread-3:终于可以吃饭啦！
pool-1-thread-1:终于可以吃饭啦！
pool-1-thread-4:终于可以吃饭啦！
