java中等待一些线程执行完之后,再去执行别的方法(后者需要使用前者返回的结果)
2018-01-06 21:13
656 查看
Java主线程等待所有子线程执行完毕在执行,这个需求其实我们在工作中经常会用到,比如用户下单一个产品,后台会做一系列的处理,为了提高效率,每个处理都可以用一个线程来执行,所有处理完成了之后才会返回给用户下单成功。
我们通过以下的几种方法来解决:
一、用sleep方法,让主线程睡眠一段时间,当然这个睡眠时间是主观的时间,是我们自己定的,这个方法不推荐,但是在这里还是写一下,毕竟是解决方法
java主线程等待所有子线程执行完毕在执行(常见面试题)
二、使用Thread的join()等待所有的子线程执行完毕,主线程在执行,thread.join()把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程。比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B。
/**
*
* 处理一个业务逻辑的场景:当一组线程都执行完之后,在执行别的线程(后者要使用前者返回的结果)
* @author Administrator
*
*/
public class ThreadDemo {
}
三、下面结合这个问题我介绍一些并发包里非常有用的并发工具类,等待多线程完成的CountDownLatch
/**
*
* 处理一个业务逻辑的场景:当一组线程都执行完之后,在执行别的线程(后者要使用前者返回的结果)
* @author Administrator
*
*/
public class ThreadDemo2 {
}
在这里说明一点,countDownLatch不可能重新初始化或者修改CountDownLatch对象内部计数器的值,一个线程调用countdown方法happen-before另外一个线程调用await方法
四、同步屏障CyclicBarrier
/**
*
* 处理一个业务逻辑的场景:当一组线程都执行完之后,在执行别的线程(后者要使用前者返回的结果)
* @author Administrator
*
*/
public class ThreadDemo3 {
}
写到这里大家不免有些疑问,countDownLatch和cyclicBarrier有什么区别呢,他们的区别:countDownLatch只能使用一次,而CyclicBarrier方法可以使用reset()方法重置,所以CyclicBarrier方法可以能处理更为复杂的业务场景。
我曾经在网上看到一个关于countDownLatch和cyclicBarrier的形象比喻,就是在百米赛跑的比赛中若使用 countDownLatch的话冲过终点线一个人就给评委发送一个人的成绩,10个人比赛发送10次,如果用CyclicBarrier,则只在最后一个人冲过终点线的时候发送所有人的数据,仅仅发送一次,这就是区别。
我们通过以下的几种方法来解决:
一、用sleep方法,让主线程睡眠一段时间,当然这个睡眠时间是主观的时间,是我们自己定的,这个方法不推荐,但是在这里还是写一下,毕竟是解决方法
java主线程等待所有子线程执行完毕在执行(常见面试题)
二、使用Thread的join()等待所有的子线程执行完毕,主线程在执行,thread.join()把指定的线程加入到当前线程,可以将两个交替执行的线程合并为顺序执行的线程。比如在线程B中调用了线程A的Join()方法,直到线程A执行完毕后,才会继续执行线程B。
/**
*
* 处理一个业务逻辑的场景:当一组线程都执行完之后,在执行别的线程(后者要使用前者返回的结果)
* @author Administrator
*
*/
public class ThreadDemo {
public static void main(String[] args) throws InterruptedException { Vector<Thread> vectors=new Vector<Thread>(); //启用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,则只在最后一个人冲过终点线的时候发送所有人的数据,仅仅发送一次,这就是区别。
相关文章推荐
- java中等待一些线程执行完之后,再去执行别的方法(后者需要使用前者返回的结果)
- java 使用Callable和Future返回线程执行的结果
- JAVA多线程实现方式主要有三种:继承Thread类、实现Runnable接口、使用ExecutorService、Callable、Future实现有返回结果的多线程。其中前两种方式线程执行完后都没
- java中等待其他线程执行完成之后,再去执行别的方法
- 子线程返回前,使循环暂停但不使主线程卡死的办法,等待子线程有返回了之后,才执行主线程下一步代码的方法
- 线程池等待一定数目的线程执行完毕之后返回结果
- Java实现等待所有子线程结束后再执行一段代码的方法
- 使用java传参调用exe并且获取程序进度和返回结果的一种方法
- Java中String类的一些方法的返回值的结果
- 活动a 使用 启动为结果 方法 启动 活动 b, b什么都不做 并返回给a,a中的 在活动结果时候 回调 是否被执行?
- Java线程等待wait通知notify方法的使用
- 声明方法java实际开发中泛型使用需要注意的一些问题
- 线程池使用FutureTask时候需要注意的一点事, 获取线程执行结果
- Java线程暂停一段时间之后继续执行的实现方法
- Java 多线程 (PART VII) 使用join()方法保证线程的执行顺序
- CountDownLatch使用countDown方法来触发其他等待线程再执行的问题
- Arrays.asList返回结果执行clear方法抛java.lang.UnsupportedOperationException
- 使用PreparedStatement的execute方法执行sql插入语句,执行成功,但是返回结果却为false
- Java执行CMD命令并等待返回结果
- 在一个有返回值的方法里使用了子线程,如何返回子线程中的值,如下代码中,我在子线程获取到了address的值,但是这个方法的返回结果是空,该如何解决?