Java并发计数器三部曲

第一篇《Java并发中同步计数器-countdowlatch 和 cyclicbarrier 的内部原理和用法》

第二篇《CountDownLatch 源码解析—— await()》

第三篇《CountDownLatch 源码解析—— countDown()》

countdowlatch 和 cyclicbarrier 的内部原理和用法

例子

1.CountDownLatch减计数，CyclicBarrier加计数。
2.CountDownLatch是一次性的，CyclicBarrier可以重用。

1、CountDownLatch

一个非常典型的应用场景是：有一个任务想要往下执行，但必须要等到其他的任务执行完毕后才可以继续往下执行。假如我们这个想要继续往下执行的任务调用一个CountDownLatch对象的await()方法，其他的任务执行完自己的任务后调用同一个CountDownLatch对象上的countDown()方法，这个调用await()方法的任务将一直阻塞等待，直到这个CountDownLatch对象的计数值减到0为止。

用法：用给定的计数初始化CountDownLath。调用countDown()方法计数减 1，在计数被减到 0之前，调用await方法会一直阻塞。减为 0之后，则会迅速释放所有阻塞等待的线程，并且调用await操作会立即返回。

ps：CountDownLath计数无法被重置，如果需要重置计数，请考虑使用CyclicBarrier.

有五个人，一个裁判。这五个人同时跑，裁判开始计时，五个人都到终点了，裁判喊停，然后统计这五个人从开始跑到最后一个撞线用了多长时间。

import java.util.concurrent.CountDownLatch;  
      
    public class Race {  
      
        public static void main(String[] args) {  
            final int num = 5;  
            final CountDownLatch begin = new CountDownLatch(1);  
            final CountDownLatch end = new CountDownLatch(num);  
      
            for (int i = 0; i < num; i++) {  
                new Thread(new AWorker(i, begin, end)).start();  
            }  
      
            // judge prepare...  
            try {  
                Thread.sleep((long) (Math.random() * 5000));  
            } catch (InterruptedException e1) {  
                e1.printStackTrace();  
            }  
      
            System.out.println("judge say : run !");  
            begin.countDown();  
            long startTime = System.currentTimeMillis();  
      
            try {  
                end.await();  
            } catch (Interrupted