public class CountDownLatch {
        //內(nèi)部類Sync繼承了AQS
        private static final class Sync extends AbstractQueuedSynchronizer {
            private static final long serialVersionUID = 4982264981922014374L;
            //構(gòu)造方法中的count其實就是傳給了AQS的state屬性
            Sync(int count) {
                setState(count);
            }
            //得到的AQS的state屬性值
            int getCount() {
                return getState();
            }
            //重寫的AQS的tryAcquireShared，在共享模式的情況下獲取鎖
            protected int tryAcquireShared(int acquires) {
                //獲取鎖的前提是state為0，表示當前未被其他線程占有
                return (getState() == 0) ? 1 : -1;
            }
            //重寫的AQS的tryReleaseShared，在共享模式下釋放鎖
            protected boolean tryReleaseShared(int releases) {
                // 減count; 當count為0時喚醒
                for (;;) {
                    int c = getState();
                    if (c == 0)  //表示釋放鎖的前提是占有鎖，也就是state的屬性值大于0
                        return false;
                    int nextc = c-1;  //state的值減1
                    if (compareAndSetState(c, nextc))  //利用CAS來改變state的值
                        return nextc == 0;  //當state的值為0時返回true
                }
            }
        }
        private final Sync sync;
        /**
         * 通過count初始化一個CountDownLatch
         *
         *在線程調(diào)用await方法后如果想通過，必須執(zhí)行count次countDown方法
         * @如果count為負數(shù)，則拋出IllegalArgumentException
         */
        public CountDownLatch(int count) {
            if (count < 0) throw new IllegalArgumentException("count < 0");
            this.sync = new Sync(count);
        }
    ================================================================================================
    				兩個核心方法，其實底層使用的AQS的方法（共享模式下）
        /**
         * 調(diào)用await方法會使當前的線程等待除非count的數(shù)值降為0或者中間拋出異常
         *
         * 如果當前的count為0，則該方法立即返回
         *
         *如果當前的count大于0，則當前線程因線程調(diào)度目的而被禁用，并且休眠，直到發(fā)生以下兩種情況之一：
         *1、調(diào)用countDown方法將count的值降為0
         *2、其他的線程打斷了當前線程，使用Thread.interrupted
         */
        public void await() throws InterruptedException {
            sync.acquireSharedInterruptibly(1);
        }
        /**
         *減count的值，如果count的值為0了，則釋放所有等待的線程
         *
         *如果當前的count值大于0，那么它是被減了。
         *如果當前的count值等于0，那么所有等待的線程被喚醒接受線程的調(diào)度
         */
        public void countDown() {
            sync.releaseShared(1);
        }
    ================================================================================================
        /**
    	 *返回count的值，用于調(diào)試或者測試
         */
        public long getCount() {
            return sync.getCount();
        }

public static void main(String[] args) throws Exception{
        CountDownLatch cd = new CountDownLatch(3);
        Thread beginGame = new Thread(new Runnable() {
            @Override
            public void run() {
                try{
                    cd.await();
                    System.out.println("歡迎來到王者榮耀，敵軍還有30秒到達戰(zhàn)場============");
                }catch(Exception e){
                    e.printStackTrace();
                }
            }
        },"beginGame");
        Thread player1 = new Thread(new Runnable() {
            @Override
            public void run() {
                try{
                    System.out.println("玩家一以準備=======");
                    cd.countDown();
                }catch(Exception e){
                    e.printStackTrace();
                }
            }
        },"player1");
        Thread player2 = new Thread(new Runnable() {
            @Override
            public void run() {
                try{
                    System.out.println("玩家二以準備=======");
                    cd.countDown();
                }catch(Exception e){
                    e.printStackTrace();
                }
            }
        },"player2");
        beginGame.start();
        player1.start();
        player2.start();
    }