java中等待一些线程执行完之后，再去执行别的方法（后者需要使用前者返回的结果）

Java主线程等待所有子线程执行完毕在执行，这个需求其实我们在工作中经常会用到，比如用户下单一个产品，后台会做一系列的处理，为了提高效率，每个处理都可以用一个线程来执行，所有处理完成了之后才会返回给用户下单成功。

我们通过以下的几种方法来解决：
一、用sleep方法，让主线程睡眠一段时间，当然这个睡眠时间是主观的时间，是我们自己定的，这个方法不推荐，但是在这里还是写一下，毕竟是解决方法

二、使用Thread的join()等待所有的子线程执行完毕，主线程在执行，thread.join()把指定的线程加入到当前线程，可以将两个交替执行的线程合并为顺序执行的线程。比如在线程B中调用了线程A的Join()方法，直到线程A执行完毕后，才会继续执行线程B。

/** * * 处理一个业务逻辑的场景：当一组线程都执行完之后，在执行别的线程（后者要使用前者返回的结果） * @author Administrator * */public class ThreadDemo { public static void main(String[] args) throws InterruptedException { Vector vectors=new Vector(); //启用5个线程 for(int i=1;i<=5;i++){ thread="" childrenthread="new" thread(new="" runnable(){="" public="" void="" run(){="" try="" {="" thread.sleep(1000);="" }="" catch="" (exception="" e)="" {="" e.printstacktrace();="" }="" system.out.println('子线程执行！');="" }="" });="" vectors.add(childrenthread);="" childrenthread.start();="" }="" 主线程="" for(thread="" thread="" :="" vectors){="" thread.join();="" 使用join来保证childrenthread的5个线程都执行完后，才执行主线程="" }="" system.out.println('主线程执行！');="">

三、下面结合这个问题我介绍一些并发包里非常有用的并发工具类，等待多线程完成的CountDownLatch

/** * * 处理一个业务逻辑的场景：当一组线程都执行完之后，在执行别的线程（后者要使用前者返回的结果） * @author Administrator * */public class ThreadDemo2 { public static void main(String[] args) throws InterruptedException { final CountDownLatch latch= new CountDownLatch(5);//使用java并发库concurrent //启用5个线程 for(int i=1;i<=5;i++){ new="" thread(new="" runnable(){="" public="" void="" run(){="" try="" {="" thread.sleep(1000);="" }="" catch="" (exception="" e)="" {="" e.printstacktrace();="" }="" system.out.println('子线程执行！');="" latch.countdown();//让latch中的数值减一="" }="" }).start();="" }="" 主线程="" latch.await();//阻塞当前线程直到latch中数值为零才执行="" system.out.println('主线程执行！');="">

在这里说明一点，countDownLatch不可能重新初始化或者修改CountDownLatch对象内部计数器的值，一个线程调用countdown方法happen-before另外一个线程调用await方法

四、同步屏障CyclicBarrier

/** * * 处理一个业务逻辑的场景：当一组线程都执行完之后，在执行别的线程（后者要使用前者返回的结果） * @author Administrator * */public class ThreadDemo3 { public static void main(String[] args) throws Exception { final CyclicBarrier barrier=new CyclicBarrier(5); //启用5个线程 for(int i=1;i<=5;i++){ new="" thread(new="" runnable(){="" public="" void="" run(){="" try="" {="" thread.sleep(1000);="" }="" catch="" (exception="" e)="" {="" e.printstacktrace();="" }="" system.out.println('子线程执行！');="" try="" {="" barrier.await();//到达屏障="" }="" catch="" (interruptedexception="" |="" brokenbarrierexception="" e)="" {="" todo="" auto-generated="" catch="" block="" e.printstacktrace();="" }="" }="" }).start();="" }="" 主线程="" barrier.await();//阻塞当前线程直到latch中数值为零才执行="" system.out.println('主线程执行！');="">

写到这里大家不免有些疑问，countDownLatch和cyclicBarrier有什么区别呢，他们的区别：countDownLatch只能使用一次，而CyclicBarrier方法可以使用reset()方法重置，所以CyclicBarrier方法可以能处理更为复杂的业务场景。

我曾经在网上看到一个关于countDownLatch和cyclicBarrier的形象比喻，就是在百米赛跑的比赛中若使用 countDownLatch的话冲过终点线一个人就给评委发送一个人的成绩，10个人比赛发送10次，如果用CyclicBarrier，则只在最后一个人冲过终点线的时候发送所有人的数据，仅仅发送一次，这就是区别。