CountDownLatchTest1.java

package four;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class CountDownLatchTest1 {
	public static void main(String[] args) {
		final CountDownLatch latch = new CountDownLatch(3);
		System.out.println("主线程开始执行 ----- ");

		ExecutorService es1 = Executors.newSingleThreadExecutor();
		es1.execute(new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(1000);
					System.out.println("线程 ： " + Thread.currentThread().getName());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				System.out.println(" 线程 " + Thread.currentThread().getName() + " 结束 ");
				latch.countDown();
			}
		});

		es1.shutdown();

		ExecutorService es2 = Executors.newSingleThreadExecutor();
		es2.execute(new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(2000);
					System.out.println("线程 ： " + Thread.currentThread().getName());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				latch.countDown();
				System.out.println(" 线程 " + Thread.currentThread().getName() + " 结束 ");
			}
		});

		es2.shutdown();

		ExecutorService es3 = Executors.newSingleThreadExecutor();
		es3.execute(new Runnable() {
			@Override
			public void run() {
				try {
					Thread.sleep(3000);
					System.out.println("线程 ： " + Thread.currentThread().getName());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
				latch.countDown();
				System.out.println(" 线程 " + Thread.currentThread().getName() + " 结束 ");
			}

		});
		es3.shutdown();
		System.out.println("两个线程执行完毕============  ");
		try {
			latch.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println("主线程执行结束==============   ");
	}
}