package threadLock;

import java.util.Random;

import java.util.concurrent.CountDownLatch;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

public class CountDownLatchTest {

    public static void main(String[] args) {

        final CountDownLatch latch1 = new CountDownLatch();

        final CountDownLatch latch2 = new CountDownLatch();

        ExecutorService service = Executors.newCachedThreadPool();

        for (int i = ; i < ; i++) {

            service.execute(new Runnable() {

                @Override

                public void run() {

                    try {

                        System.out.println("线程"

                                + Thread.currentThread().getName() + "正在等待命令。");

                        latch1.await();

                        System.out.println("线程"

                                + Thread.currentThread().getName() + "正在处理。");

                        Thread.sleep(new Random().nextInt());

                        latch2.countDown();

                    } catch (InterruptedException e) {

                        e.printStackTrace();

                    }

                }

            });

        }

        try {

            Thread.sleep();

            System.out.println("thread main 发布命令。");

            System.out.println("thread main 正在收集各线程响应。");

            latch1.countDown();

            latch2.await();

            System.out.println("thread main已收集所有线程的响应。");

        } catch (InterruptedException e) {

            e.printStackTrace();

        }

    }

}