java并发编程学习:如何等待多个线程执行完成后再继续后续处理(synchronized、join、FutureTask、CyclicBarrier)
2017-08-18 17:03
881 查看
多线程应用中,经常会遇到这种场景:后面的处理,依赖前面的N个线程的处理结果,必须等前面的线程执行完毕后,后面的代码才允许执行。
在我不知道CyclicBarrier之前,最容易想到的就是放置一个公用的static变量,假如有10个线程,每个线程处理完上去累加下结果,然后后面用一个死循环(或类似线程阻塞的方法),去数这个结果,达到10个,说明大家都爽完了,可以进行后续的事情了,这个想法虽然土鳖,但是基本上跟语言无关,几乎所有主流编程语言都支持。
输出结果:
thread 0 done
thread 0 => 1
thread 9 done
thread 9 => 2
thread 1 done
thread 1 => 3
thread 3 done
thread 3 => 4
thread 7 done
thread 7 => 5
thread 6 done
thread 6 => 6
thread 2 done
thread 2 => 7
thread 4 done
thread 4 => 8
thread 8 done
thread 8 => 9
thread 5 done
thread 5 => 10
-----------
所有thread执行完成!
除了这个方法,还可以借助FutureTask,达到类似的效果,其get方法会阻塞线程,等到该异步处理完成。缺点就是,FutureTask调用的是Callable,必须要有返回值,所以就算你不想要返回值,也得返回点啥
执行结果:
task0 done
task1 done
task2 done
task3 done
task4 done
task5 done
task6 done
task7 done
task8 done
task9 done
-----------
所有task执行完成!
此外,Thread的Join方法也可以实现类似的效果,主要代码如下:
当然,这个需求最“正统”的解法应该是使用CyclicBarrier,它可以设置一个所谓的“屏障点”(或称集合点),好比在一项团队活动中,每个人都是一个线程,但是规定某一项任务开始前,所有人必须先到达集合点,集合完成后,才能继续后面的任务。
thread 9 done,正在等候其它线程完成...
thread 5 done,正在等候其它线程完成...
thread 0 done,正在等候其它线程完成...
thread 6 done,正在等候其它线程完成...
thread 4 done,正在等候其它线程完成...
thread 2 done,正在等候其它线程完成...
thread 3 done,正在等候其它线程完成...
thread 8 done,正在等候其它线程完成...
thread 7 done,正在等候其它线程完成...
thread 1 done,正在等候其它线程完成...
-----------
所有thread执行完成!
参考文章:
http://ifeve.com/concurrency-cyclicbarrier/
http://ifeve.com/thread-synchronization-utilities-5/
http://ifeve.com/semaphore-countdownlatch-cyclicbarrier-phaser-exchanger-in-java/
http://ifeve.com/thread-management-7/
在我不知道CyclicBarrier之前,最容易想到的就是放置一个公用的static变量,假如有10个线程,每个线程处理完上去累加下结果,然后后面用一个死循环(或类似线程阻塞的方法),去数这个结果,达到10个,说明大家都爽完了,可以进行后续的事情了,这个想法虽然土鳖,但是基本上跟语言无关,几乎所有主流编程语言都支持。
thread 0 done
thread 0 => 1
thread 9 done
thread 9 => 2
thread 1 done
thread 1 => 3
thread 3 done
thread 3 => 4
thread 7 done
thread 7 => 5
thread 6 done
thread 6 => 6
thread 2 done
thread 2 => 7
thread 4 done
thread 4 => 8
thread 8 done
thread 8 => 9
thread 5 done
thread 5 => 10
-----------
所有thread执行完成!
除了这个方法,还可以借助FutureTask,达到类似的效果,其get方法会阻塞线程,等到该异步处理完成。缺点就是,FutureTask调用的是Callable,必须要有返回值,所以就算你不想要返回值,也得返回点啥
task0 done
task1 done
task2 done
task3 done
task4 done
task5 done
task6 done
task7 done
task8 done
task9 done
-----------
所有task执行完成!
此外,Thread的Join方法也可以实现类似的效果,主要代码如下:
thread 5 done,正在等候其它线程完成...
thread 0 done,正在等候其它线程完成...
thread 6 done,正在等候其它线程完成...
thread 4 done,正在等候其它线程完成...
thread 2 done,正在等候其它线程完成...
thread 3 done,正在等候其它线程完成...
thread 8 done,正在等候其它线程完成...
thread 7 done,正在等候其它线程完成...
thread 1 done,正在等候其它线程完成...
-----------
所有thread执行完成!
参考文章:
http://ifeve.com/concurrency-cyclicbarrier/
http://ifeve.com/thread-synchronization-utilities-5/
http://ifeve.com/semaphore-countdownlatch-cyclicbarrier-phaser-exchanger-in-java/
http://ifeve.com/thread-management-7/
相关文章推荐
- java并发编程学习:如何等待多个线程执行完成后再继续后续处理(synchronized、join、FutureTask、CyclicBarrier)
- java线程池主线程等待子线程执行完成后再继续处理后面工作
- [置顶] java 并发编程实战书籍学习 第五章,CountDownLatch,FutureTask,CyclicBarrier,Semaphore学习
- java线程池主线程等待子线程执行完成后再继续处理后面工作
- Java并发:等待事件发生后所有线程继续执行
- Java并发编程深入学习——CountDownLatch、CyclicBarrier和Semaphore
- java线程池主线程等待子线程执行完成后再继续处理后面工作
- Java 编程下 CyclicBarrier 中的线程等待
- [Java并发]使用CountDownLatch和CyclicBarrier等待多线程完成
- 如何等待一个线程完成后才继续执行之后的操作
- Java并发编程-12-等待多个并发事件的完成-CountDownLatch
- Java并发:等待事件发生后所有线程继续执行
- 使用java并发工具栅栏(CyclicBarrier)实现多线程等待,同一时刻执行共同任务
- Java 编程下 CyclicBarrier 中的线程等待
- 《Java 7 并发编程指南》学习概要 (3)Semaphore, CountDownLatch, CyclicBarrier , Phaser, Exchanger
- Java并发:主线程等待多个子线程执行完才继续执行
- Java并发学习之八——在线程中处理不受控制的异常
- 并发编程--等待多个并发事件的完成
- 《Java 7 并发编程指南》学习概要 (6) Fork/Join
- Java并发学习之六——等待线程的终结