并发编程关键字Semaphore和CountDownLatch、CyclicBarrier

Semaphore     [ˈseməfɔːr]   

        字面意思：信号量；作用：控制访问特定资源的线程数目，底层依赖AQS的状态State.

//许可线程的数量
Semaphore semaphore = new Semaphore(2);
//公平性，下次执行会是等待最久的线程
Semaphore semaphore2 = new Semaphore(2,true);

//阻塞并获取许可
semaphore.acquire();
//释放许可
semaphore.release();

使用场景：资源访问，服务限流（Hystrix限流有基于信号量的方式）

CountDownLatch

        能够使一个线程等待其他线程完成各自的工作后再执行。如：应用程序主线程希望在负责启动框架服务的线程已经启动所有的框架服务之后再执行。

场景：Zookeeper分布式锁，Jemeter模拟高并发

        CountDownLatch通过一个计数器来实现，计数器初始值为线程的数量，每当一个线程完成了自己的任务后，计数器的值就会减1.当计数器值到达0时，表示所有的线程已经完成了任务，然后在闭锁上等待的线程就可以恢复执行任务。

//初始化计数器
CountDownLatch countDownLatch = new CountDownLatch(2);
//子线程内部调用，计数器减1
countDownLatch.countDown();
//主线程等待，直至所有子线程执行完毕任务，继续
countDownLatch.await();

CyclicBarrier         [ˈsaɪklɪkbæriər] 

        栅栏屏障，让一组线程到达一个屏障（同步点）时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续运行。

场景：用于多线程计算数据，最后合并计算结果。

        // 主线程
        CyclicBarrier cyclicBarrier = new CyclicBarrier(10, new Runnable() {
            @Override
            public void run() {
                //开启子线程
                new Thread(new Runnable() {
                    @Override
                    public void run() {
                        //子线程,内部执行，代表子线程已到达同步点
                        cyclicBarrier.await();    
                    }
                }).start();
            }
        });
        //等待所有子线程执行完毕后，继续往下执行
        cyclicBarrier.await();