package com.unicss;

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class TestCountDownLatch {

public static void main(String[] args) throws InterruptedException {

// 开始的倒数锁

final CountDownLatch begin = new CountDownLatch(1);

// 结束的倒数锁

final CountDownLatch end = new CountDownLatch(10);

// 十名选手

final ExecutorService exec = Executors.newFixedThreadPool(10);

for (int index = 0; index < 10; index++) {

final int NO = index + 1;

Runnable run = new Runnable() {

@Override

public void run() {

try {

//初始值是1，因此只会阻塞一次

begin.await();//在当前计数到达零之前，await() 方法会一直受阻塞（即当前线程一直等待），当计数到达零时，会释放所有等待的线程

Thread.sleep((long) (Math.random() * 10000));

System.out.println("No." + NO + " arrived");

} catch (InterruptedException e) {

} finally {

end.countDown();

}

}

};

exec.submit(run);

}

System.out.println("Game Start");

begin.countDown();

end.await(); //阻塞，等待end.countDown()全部执行完

System.out.println("Game Over");

exec.shutdown();

}

}