首页 > 经验记录 > java > java多线程应用_并发工具类之循环屏障(CyclicBarrier)

java多线程应用_并发工具类之循环屏障(CyclicBarrier)

CyclicBarrier这个类的字面意思是循环屏障,跟CountDownLatch有些像,但不一样。关于CountDownLatch我在该爬虫项目中使用过,没有单独的文章进行讲解。

CyclicBarrier跟CountDownLatch的区别是:
CountDownLatch只计数1次
CyclicBarrier可以通过reset()重置计数,实现更复杂的业务,也会在其等待完毕释放锁后重置计数。

说明:
CyclicBarrier有2个构造
CyclicBarrier(int parties) 设置一个任务的参与数
CyclicBarrier(int parties,Runnable barrierAction) 设置一个任务的参与数和优先执行的barrierAction

步骤:
1、设置任务参与数,每个参与数达到相应阶段后,执行await方法。
2、当最后一个参与者进入await的阶段后,则停止阻塞

注意: barrierAcction屏障动作是由最后一个达到的子线程执行的

 

可以看我下面的代码,以学生去郊游为例,展示了其线程阻塞和可循环使用的功能:

 

输出语句为:

12 学生 已达到学校门口
13 学生 已达到学校门口
11 学生 已达到学校门口
14 学生 已达到学校门口
15 学生 已达到学校门口
15~~大家都到齐了,出发干下件事咯
15 学生 已经坐上 旅游大巴
13 学生 已经坐上 旅游大巴
14 学生 已经坐上 旅游大巴
11 学生 已经坐上 旅游大巴
12 学生 已经坐上 旅游大巴
12~~大家都到齐了,出发干下件事咯
12 学生到达景点
13 学生到达景点
15 学生到达景点
11 学生到达景点
14 学生到达景点
14~~大家都到齐了,出发干下件事咯触发

 

的确实现了线程等待其他线程完成的功能

注意观察线程ID,可以发现每次触发 barrierAction 屏障动作都是由最后一个线程来执行的


EA PLAYER &

历史记录 [ 注意:部分数据仅限于当前浏览器 ]清空

      00:00/00:00