public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
    // 總數(shù)是6，必須要執(zhí)行任務(wù)的時(shí)候，再使用    ！
    CountDownLatch countDownLatch = new CountDownLatch(6);
    for (int i = 1; i <=6 ; i++) {    
        new Thread(()->{
        System.out.println(Thread.currentThread().getName()+" Go out");
        countDownLatch.countDown(); // 數(shù)量-1
        },String.valueOf(i)).start();
    }  
    countDownLatch.await(); // 等待計(jì)數(shù)器歸零，然后再向下執(zhí)行
    System.out.println("Close Door");
    }
}

public class CyclicBarrierDemo {
    public static void main(String[] args) {
         // 召喚龍珠的線程
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{
            System.out.println("召喚神龍成功！");
        });
        for (int i = 1; i <=7 ; i++) {
            final int temp = i;
            // lambda能操作到 i 嗎
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"收集"+temp+"個(gè)龍珠");
                try {
                cyclicBarrier.await(); // 等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

public class SemaphoreDemo {
    public static void main(String[] args) {
        // 線程數(shù)量：停車位! 限流！
        Semaphore semaphore = new Semaphore(3);
        for (int i = 1; i <=6 ; i++) {
            new Thread(()->{
            // acquire() 得到
            try {
                semaphore.acquire();
                System.out.println(Thread.currentThread().getName()+"搶到車位");
                TimeUnit.SECONDS.sleep(2);
                System.out.println(Thread.currentThread().getName()+"離開車位");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                semaphore.release(); // release() 釋放
            }
        },String.valueOf(i)).start();
        }
    }
}