首页 > 经验记录 > 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屏障动作是由最后一个达到的子线程执行的
 
可以看我下面的代码,以学生去郊游为例,展示了其线程阻塞和可循环使用的功能:

package top.yibobo.test;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierTest {
    public static void main(String[] args) {
        test();
    }
    private static void test() {
        CyclicBarrier cb = new CyclicBarrier(5, () ->
                System.out.println(Thread.currentThread().getId() + "~~大家都到齐了,出发干下件事咯"));
        for (int i = 0; i < 5; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getId() + " 学生 已达到学校门口");
                await(cb);
                System.out.println(Thread.currentThread().getId() + " 学生 已经坐上 旅游大巴");
                await(cb);
                System.out.println(Thread.currentThread().getId() + " 学生到达景点");
                await(cb);
            }).start();
        }
    }
    private static void await(CyclicBarrier cb){
        try {
            cb.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (BrokenBarrierException e) {
            e.printStackTrace();
        }
    }
}

 
输出语句为:
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