多线程笔记(5) -并发工具类-CyclicBarrier，Semaphore，Exchange

1,CyclicBarrier

屏障：当线程Ta先执行到了await方法时候，等待；然后Tb又执行到了await方法，继续等待，直到最后一个线程执行到了他自己的await方法之后，图中的三个线程才会继续一块走下去，当传入barrierAction时，所有线程执行完await方法后，会执行barrierAction进行汇总，汇总结束后执行await方法的线程才会继续运行

屏障可以多次使用，await可以反复调用

CyclicBarrier构造方法传入的数字必须和执行任务的线程数量一致

与countDownLatch的区别：

1，CyclicBarrier计数器可以多次使用，同时计数器可以使用reset()方法重置，countDownLatch只能调用一次

2，CyclicBarrier工作线程本身之间相互协调，countDownLatch是利用外部的线程来协调执行

3，CyclicBarrier的计数器必须等于线程数，countDownLatch的控制计数器和线程大小没有必然关系

4，CyclicBarrier可以进行汇总，只需传入barrierAction， countDownLatch执行的时候，不能进行其他的操作，比如汇总计算结果

代码示例

public class CyclicBarrierTest {
	// 自定义工作线程
	private static class Worker extends Thread {
		private CyclicBarrier cyclicBarrier;
		
		public Worker(CyclicBarrier cyclicBarrier) {
			this.cyclicBarrier = cyclicBarrier;
		}
		
		@Override
		public void run() {
			super.run();
			
			try {
				System.out.println(Thread.currentThread().getName() + "开始等待其他线程");
				cyclicBarrier.await();
				System.out.println(Thread.currentThread().getName() + "开始执行");
				// 工作线程开始处理，这里用Thread.sleep()来模拟业务处理
				Thread.sleep(1000);
				System.out.println(Thread.currentThread().getName() + "执行完毕");
			} catch (Exception e) {
				e.printStackTrace();
			}
		}
	}
 
	public static void main(String[] args) {
		int threadCount = 3;
		CyclicBarrier cyclicBarrier = new CyclicBarrier(threadCount);
		
		for (int i = 0; i < threadCount; i++) {
			System.out.println("创建工作线程" + i);
			Worker worker = new Worker(cyclicBarrier);
			worker.start();
		}
	}
}