Java主线程在子线程执行完毕后再执行

一、join()

Thread中的join()方法就是同步，它使得线程之间由并行执行变为串行执行。

public class MyJoinTest { public static void main(String[] args) { Vector<Thread> threadVector = new Vector<Thread>(); for (int i = 0;i<5;i++){ Thread childThread = new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("子线程执行..."); } }); threadVector.add(childThread); childThread.start(); } for (Thread t : threadVector){ try { t.join(); } catch (InterruptedException e) { e.printStackTrace(); } } System.out.println("主线程执行......"); } }

我们使用循环创建了5个子线程，把它们放到Vector对象中，并启动这个线程。遍历Vector，获取每一个子线程。在main线程中调用子线程的join方法，那么main线程放弃cpu的使用权，直到所有的子线程执行完毕，才会执行main线程。执行结果如下：

子线程执行...
子线程执行...
子线程执行...
子线程执行...
子线程执行...
主线程执行......

二、CountDownLatch

public class CountDownLatchTest { public static void main(String[] args) { final CountDownLatch latch = new CountDownLatch(5); for (int i = 0; i < 5; i++) { new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("子线程执行..."); latch.countDown();//让latch中的值减1
 } }).start(); } try { latch.await();//阻塞当前线程，直到latch的值为0
        } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("主线程执行......"); } }

三、CyclicBarrier

public class CyclicBarrierTest { public static void main(String[] args) throws BrokenBarrierException, InterruptedException { final CyclicBarrier barrier = new CyclicBarrier(5); for (int i = 0; i < 4; i++) { new Thread(new Runnable() { @Override public void run() { try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } System.out.println("子线程执行..."); try { barrier.await();//到达屏障
                    } catch (Exception e) { e.printStackTrace(); } } }).start(); } barrier.await(); System.out.println("主线程执行......"); } }

CountDownLatch和CyclicBarrier有什么区别呢？
他们的区别：CountDownLatch只能使用一次，而CyclicBarrier方法可以使用reset()方法重置，所以CyclicBarrier方法可以处理更为复杂的业务场景。