JUC-CountDownLatch基础篇
JUC-CountDownLatch源码分析
JUC-Semaphore基础篇
JUC-Semaphore源码分析
JUC-ReentrantReadWriteLock锁基础篇
JUC-ReentrantReadWriteLock锁源码分析
JUC-ReentrantLock锁基础篇
JUC-ReentrantLock锁源码分析
JUC-CyclicBarrier基础篇
JUC-CyclicBarrier源码分析
文章目录
- 1.概念
- 2.常用方法
- 3.例子
1.概念
CyclicBarrier顾名思义叫做循环栅栏,它是多个线程之间的同步工具类。它的作用就是会让所有线程都等待完成后才会继续下一步行动。它与JUC另一个多个线程之间的同步工具类CountDownLatch类似,但是功能比CountDownLatch更加强大(它们之间的区别请看JUC-CountDownLatch基础篇)
场景举例:比如现在有一个门,门上有5把锁,此时有五个人需要通过这扇门,它们每个人只能打开一把锁,所以执行情况是,来一个人开一把锁,然后等着,直到最后一个人来了打开了最后一把锁。此时5个人才可以通过这扇门。
2.常用方法
CyclicBarrier 提供了一些常用的方法:
方法 | 说明 |
---|---|
await() | parties的值减1,减1后,如果parties不为0,使当前线程进入条件队列进行等待,当前线程被阻塞。线程唤醒条件:1.直到其他的线程调用await将parties减1,让parties的值变成了0。2当前线程发生了中断。3.栅栏被强制打破了(调用了breakBarrier()方法)。 |
await(long timeout, TimeUnit unit) | 带超时时间的await()。超过指定时间,则线程取消阻塞 |
getParties() | 获取当前parties的值 |
isBroken() | 判断栅栏是否被打破了(即是否调用了breakBarrier()方法) |
reset() | 使得CyclicBarrier回归初始状态。做两件事情:1. 如果有正在等待的线程,则会抛出BrokenBarrierException异常,且这些线程停止等待,继续执行.2.将是否破损标志位broken置为false |
3.例子
下面代码演示5个线程它们之间相互等待对方的事情都干完了,才接着执行下面的事情
public class CyclicBarrierTest {
public static void main(String[] args) throws BrokenBarrierException, InterruptedException {
//设置parties的初始值为5
CyclicBarrier cyclicBarrier = new CyclicBarrier(5, new Runnable() {
@Override
//栅栏被打开了后所要做的事情
public void run() {
System.out.println("通过了栅栏");
}
});
for (int i = 0; i < 5; i++) {
new Thread("thread"+i){
@Override
public void run() {
try {
System.out.println("线程:" + Thread.currentThread().getName() + "的事情干完了,等待其他的线程都干完它们的事情,才接着干下面的事情");
//每调用一次await方法,parties值先减1,如果parties不为0,则阻塞住。
//直到parties的值为0,栅栏被打开,才继续往下执行
//返回值await表示当前线程调用了await()后,parties当前的值是多少
int await = cyclicBarrier.await();
System.out.println("线程:" + Thread.currentThread().getName() + " 通过了栅栏,接着干后面的事情");
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}.start();
System.out.println();
}
}
}
执行结果: