Java并发工具类CyclicBarrier
- - CSDN博客编程语言推荐文章CyclicBarrier同步屏障. java并发工具类中有一个叫做CyclicBarrier的类,与CountDownLatch类似,都可以实现线程间的同步,但是差别是CyclicBarrier是可重置的同步屏障. 想象一个场景,有N个人不同时间走到一扇门,因为门需要N个人合力才能推开,所以人不足N个时,只能阻塞在此,等到N个人都到了之后,可以推开门,继续进行之前的工作.
java并发工具类中有一个叫做CyclicBarrier的类,与CountDownLatch类似,都可以实现线程间的同步,但是差别是CyclicBarrier是可重置的同步屏障。
想象一个场景,有N个人不同时间走到一扇门,因为门需要N个人合力才能推开,所以人不足N个时,只能阻塞在此,等到N个人都到了之后,可以推开门,继续进行之前的工作。CyclicBarrier就是这扇门。
看看下面的代码,定义了一个线程数为2的,CyclicBarrier,并在主线程和另外一个线程中调用await进行阻塞:
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class Main {
static CyclicBarrier cyclicBarrier = new CyclicBarrier(2);
public static void main(String[] args) throws InterruptedException, BrokenBarrierException{
new Thread(new Runnable() {
@Override
public void run() {
System.out.println("thread 1 start");
try {
cyclicBarrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println("thread 1 end");
}
}).start();
System.out.println("thread 2 start");
cyclicBarrier.await();
System.out.println("thread 2 end");
}
}
根据线程调度的顺序,执行结果又多种,一种是:
thread 2 start
thread 1 start
thread 1 end
thread 2 end
但是所有执行效果的共同点是,必须所有线程都在await同步点阻塞之后,才能进行下一步的操作。
可以调用CyclicBarrier的reset()方法进行重置,以便在复杂场景中进行错误恢复等操作。
另外CyclicBarrier还有如下的构造函数:
public CyclicBarrier(int parties, Runnable barrierAction) {
if (parties <= 0) throw new IllegalArgumentException();
this.parties = parties;
this.count = parties;
this.barrierCommand = barrierAction;
}
可以提供一个Runnable的参数,在线程都到达屏障时,优先执行barrierAction。