您的位置:首页 > 编程语言

并发编程工具之二:CyclicBarrier 用法

2017-11-23 15:40 741 查看

CyclicBarrier 用法

从字面上这个类可以理解为环形屏障,它可以协同多个线程,让多个线程在这个屏障前等待。当所有线程都达到这个屏障时,再一起执行后续的动作。如下图:



三个线程各有一个barrier.await,那么任何一个线程执行到barrier.await时就会进入阻塞状态进行等待,知道三个线程都达到了barrier.await才会同时从await返回,就需后续的工作。此外,如果在构造CyclicBarrier时设置了Runnable实现,那么最后一个到barrier.await的线程会执行Runnable的run方法。



结合例子看一下:

public class TCyclicBarrierestDemo {

private static int count = 10;

public static void main(String[] args) {
CyclicBarrier cb = new CyclicBarrier(count, new Runnable() {
@Override
public void run() {
System.out.println("Runnable实现方法运行了");//当所有线程到达“屏障”时执行
}
});

for (int i = 0; i < count; i++) {
new Thread(new WorkerThread(cb)).start();
}
}

}

class WorkerThread implements Runnable{
CyclicBarrier barrier;
public WorkerThread(CyclicBarrier b){
this.barrier = b;
}
@Override
public void run() {
try{
System.out.println("线程到达屏障,开始等待");
barrier.await();//线程在这里等待,直到所有线程都到达“屏障”。
System.out.println("线程"+Thread.currentThread().getName()+" 开始后续工作");
}catch(Exception e){
e.printStackTrace();
}
}
}
运行结果:
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
线程到达屏障,开始等待
Runnable实现方法运行了
线程Thread-8 开始后续工作
线程Thread-5 开始后续工作
线程Thread-1 开始后续工作
线程Thread-6 开始后续工作
线程Thread-9 开始后续工作
线程Thread-4 开始后续工作
线程Thread-0 开始后续工作
线程Thread-7 开始后续工作
线程Thread-2 开始后续工作
线程Thread-3 开始后续工作
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签:  线程