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屏障动作是由最后一个达到的子线程执行的

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

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 屏障动作都是由最后一个线程来执行的