主线程等候所有子线程执行完毕后再执行

主线程等待所有子线程执行完毕后再执行
        主线程等待所有子线程执行完毕后再执行主线程,需要用到线程计数器java.util.concurrent.CountDownLatch;也可以使用join()方法,但join()方法是同步的,失去了线程并发的意义。所以,一般情况下建议使用线程计数器。

public class TestThread implements Runnable{

	//线程计数器
	private CountDownLatch threadsSignal;  
	public TestThread(CountDownLatch threadsSignal) {  
		this.threadsSignal = threadsSignal;  
	}  
	
	public void run() {
		System.out.println(Thread.currentThread().getName() + "开始运行");
		//业务逻辑
		
		
		System.out.println(Thread.currentThread().getName() + "结束运行");
        //线程结束时计数器减1
        threadsSignal.countDown();
	}
	
	public static void main(String[] args) throws Exception {
		//主线程开始
		System.out.println(Thread.currentThread().getName() + "开始运行");
		//初始化countDown
		CountDownLatch threadSignal = new CountDownLatch(5);
		//每个线程共用一个对象
		TestThread testThread = new TestThread(threadSignal);
		for (int i = 0; i < 5 ; i++) { 
			/**
			 * 每个线程持有一个对象
			 * TestThread testThread = new TestThread(threadSignal);
			 */
			Thread t = new Thread(testThread,"第"+(i+1)+"个线程");  
			t.start();
			/**
			 * join()方法主要是让调用该方法的thread完成run方法里面的东西后, 再执行join()方法后面的代码(同步)
			 * t.join();
			 */
		}  
		
		//等待所有子线程执行完
		threadSignal.await();
		//打印结束标记
		System.out.println(Thread.currentThread().getName() + "运行结束");  
	}
}