Java并发组件二之CyclicBarriar
2024-09-30 14:15:07
使用场景:
多个线程相互等待,直到都满足条件之后,才能执行后续的操作。CyclicBarrier描述的是各个线程之间相互等待的关系。
使用步骤:
- 正常实例化:CyclicBarrier sCyclicBarrier=new CyclicBarrier(3);
- 带runnable的实例化,打破屏障时,优先执行Runnable:CyclicBarrier sCyclicBarrier=new CyclicBarrier(3,new Runnable(){//todo});
- await线程:sCyclicBarrier.await();
- 当wait线程数量为,count值时。唤醒所有等待线程。
原理:这里直接用源码解释(后续补充)
- 锁用的是ReentrantLock重入锁。ReentrantLock lock = new ReentrantLock()
- 获取该锁的condition实例。Condition trip = lock.newCondition()
- wait线程,用的是Condition.await
- signal线程,用的是Condition.signalAll
- 两个构造函数,初始化parties值,count值,以及Runnable(唤醒时优先执行runnable)
- count值是用来计算线程数的。每有一个线程执行了await方法,--count。直到count==0
- await方法,包含了是否超时,以及超时时间
- dowait是线程wait的主要逻辑代码。当count==0时执行唤醒操作。不为0时,进入for循环,执行Condition.await。
- dowait中的for循环是为了超时操作的逻辑。
- 正常跳出for循环是通过dowait方法中的(nextGeneration()重新实例化了gennaration)
- breakBarrier() 打破屏障,唤醒所有wait线程
- nextGeneration() 更新状态,唤醒所有wait线程
- reset()重置状态。里面调用了breakBarrier()和nextGeneration()
最新文章
- 利用npoi导出Excel
- Linux文件标示
- Log4cplus使用
- 创建线程方式-GCD
- PHP防止页面刷新、重复提交数据
- CSS user-select属性拾遗
- mysql----用户root被删除或忘记root密码的解决方案
- 联想K82------智能电视行业的野蛮入侵者
- jquery 重复事件
- MAC系统操作指令汇总
- Lucene的配置及创建索引全文检索
- break退出循环分析
- How to find SPRO path by t-code name
- json和数组的区别
- Python使用filetype精确判断文件类型 (文件类型获取)
- Spring读取配置文件 @Value
- Android -- DiskLruCache
- spine-unity3D 学习笔记
- 内置锁(一)synchronized 介绍与用法
- nginx简介和配置gd
热门文章
- 查看权限详情 将部门大类单据整合,将子类单据id去重合并
- JAVA_JNI字段描述符“([Ljava/lang/String;)V”(Android)
- Java学习日报7.17
- linux零基础之--使用putty配置
- flume将数据写入各个组件
- OpenTelemetry - 云原生下可观测性的新标准
- 【MyBatis】MyBatis 延迟加载策略
- 号称能将STW干掉1ms的Java垃圾收集器ZGC到底是个什么东西?
- Vue基础语法与指令
- 十七:SQL注入之二次加解密,DNS注入