主线程等候所有子线程执行完毕后再执行
主线程等待所有子线程执行完毕后再执行
主线程等待所有子线程执行完毕后再执行主线程,需要用到线程计数器java.util.concurrent.CountDownLatch;也可以使用join()方法,但join()方法是同步的,失去了线程并发的意义。所以,一般情况下建议使用线程计数器。
主线程等待所有子线程执行完毕后再执行主线程,需要用到线程计数器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() + "运行结束"); } }