循环障删(CyclicBarrier)

2024-04-14 08:32
文章标签 循环 cyclicbarrier 障删

本文主要是介绍循环障删(CyclicBarrier),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

  为了更好的理解CyclicBarrier的应用,我们需要在现实生活中找到一个合适的场景;大家应该都有旅游的经验,景区通常都有旅游大巴,这些大巴的作用就是把旅客从游客中心运送到景点的入口;

  1. 首先是旅客在游客中心购买门票;
  2. 旅客就到大巴集散处排队上车;
  3. 排队人数达到了一车大巴的人数后(载客人数为2人),这些游客就上车;
  4. 大巴就启动出发将这一车游客载到景点;
  5. 继续刚才的规则……

所以我们可以把一个游客的买票排队上车抽象为一个线程;大巴启动出发抽象为另外一个线程;

/*** CyclicBarrier** @author X.T. LI* @version V1.0* @since 2022/7/21*/
public class CloneablePerformance {public static void main(String[] args) {CyclicBarrier waitForCountTo2 = new CyclicBarrier(2, new Bus());ExecutorService executorService = Executors.newCachedThreadPool();for (int i = 1; i < 4; i++) {executorService.submit(new Traveler(waitForCountTo20, i));}}
}@Slf4j
class Traveler implements Runnable {CyclicBarrier waitForCountTo20;Integer travelerNo;public Traveler(CyclicBarrier waitForCountTo20, Integer travelerNo) {this.waitForCountTo20 = waitForCountTo20;this.travelerNo = travelerNo;}@Overridepublic void run() {log.info("Buy ticket. Traveler{} buy ticket.", travelerNo);log.info("Get on car. Traveler{} get on car.", travelerNo);try {waitForCountTo20.await();} catch (InterruptedException | BrokenBarrierException e) {e.printStackTrace();}}
}@Slf4j
class Bus implements Runnable {@Overridepublic void run() {log.info("Bus runs.");}
}

运行后的结果

Buy ticket. 3-Traveler buy ticket.Thread id is 14
Buy ticket. 2-Traveler buy ticket.Thread id is 13
Buy ticket. 1-Traveler buy ticket.Thread id is 12
Bus runs.Thread id is 14
Get on car. 3-Traveler get on car. Thread id is 14
Get on car. 2-Traveler get on car. Thread id is 13

从上述输出结果可以看出:

  • 上车的只有3号和2号游客,他两上车后同时将屏障重置为了2,这里正好和CyclicBarrier单词中的Cyclic对应;
  • 1号游客因为买票后时第3个去排队的,所以它没能上车。需要等待下一辆车,如果此时由第4个乘客个票后来等待那么他们两就会触发一辆车;

注意我们构建循环屏障的时候使用的是CyclicBarrier#CyclicBarrier(int parties, Runnable barrierAction);这里的barrierAction是由最后一个触发屏障的线程来执行的,所以从上述运行结果可以发现3号游客的线程号和大巴开车的线程号是一样的;

构造函数

public CyclicBarrier(int parties)

public CyclicBarrier(int parties, Runnable barrierAction)

int CyclicBarrier#getParties() 

return the number of parties required to trip this barrier

这篇关于循环障删(CyclicBarrier)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/902562

相关文章

好题——hdu2522(小数问题:求1/n的第一个循环节)

好喜欢这题,第一次做小数问题,一开始真心没思路,然后参考了网上的一些资料。 知识点***********************************无限不循环小数即无理数,不能写作两整数之比*****************************(一开始没想到,小学没学好) 此题1/n肯定是一个有限循环小数,了解这些后就能做此题了。 按照除法的机制,用一个函数表示出来就可以了,代码如下

poj3750约瑟夫环,循环队列

Description 有N个小孩围成一圈,给他们从1开始依次编号,现指定从第W个开始报数,报到第S个时,该小孩出列,然后从下一个小孩开始报数,仍是报到S个出列,如此重复下去,直到所有的小孩都出列(总人数不足S个时将循环报数),求小孩出列的顺序。 Input 第一行输入小孩的人数N(N<=64) 接下来每行输入一个小孩的名字(人名不超过15个字符) 最后一行输入W,S (W < N),用

校验码:奇偶校验,CRC循环冗余校验,海明校验码

文章目录 奇偶校验码CRC循环冗余校验码海明校验码 奇偶校验码 码距:任何一种编码都由许多码字构成,任意两个码字之间最少变化的二进制位数就称为数据检验码的码距。 奇偶校验码的编码方法是:由若干位有效信息(如一个字节),再加上一个二进制位(校验位)组成校验码。 奇校验:整个校验码中1的个数为奇数 偶校验:整个校验码中1的个数为偶数 奇偶校验,可检测1位(奇数位)的错误,不可纠错。

react笔记 8-17 属性绑定 class绑定 引入图片 循环遍历

1、绑定属性 constructor(){super()this.state={name:"张三",title:'我是一个title'}}render() {return (<div><div>aaaaaaa{this.state.name}<div title={this.state.title}>我是一个title</div></div></div>)} 绑定属性直接使用花括号{}   注

Spring是如何解决循环依赖?

现象解释: 在Spring框架中,循环依赖(Circular Dependency)是指两个或多个Bean之间相互依赖,形成了一个循环。例如,Bean A依赖于Bean B,而Bean B又依赖于Bean A。Spring通过多种机制解决循环依赖问题,具体来说,主要有以下几种方式: 1.三级缓存机制 Spring容器在实例化Bean时使用了三级缓存来解决循环依赖,主要涉及三个缓存结构: 一级

FPGA开发:条件语句 × 循环语句

条件语句 if_else语句 if_else语句,用来判断是否满足所给定的条件,根据判断的结果(真或假)决定执行给出的两种操作之一。 if(表达式)语句; 例如: if(a>b) out1=int1; if(表达式)         语句1; else         语句2; 例如: if(a>b)out1=int1;elseout1=int2; if(表达式1) 语句1; els

shell循环sleep while例子 条件判断

i=1# 小于5等于时候才执行while [ ${i} -le 5 ]doecho ${i}i=`expr ${i} + 1`# 休眠3秒sleep 3doneecho done 参考 http://c.biancheng.net/cpp/view/2736.html

【语音告警】博灵智能语音报警灯JavaScript循环播报场景实例-语音报警灯|声光报警器|网络信号灯

功能说明 本文将以JavaScript代码为实例,讲解如何通过JavaScript代码调用博灵语音通知终端 A4实现声光语音告警。主要博灵语音通知终端如何实现无线循环播报或者周期播报的功能。 本代码实现HTTP接口的声光语音播报,并指定循环次数、播报内容。由于通知终端采用TTS语音合成技术,所以本次案例中无需预先录制音频。 代码实战 为了通过JavaScript调用博灵语音通知终端,实现HT

【JavaScript】在循环内使用闭包

================== 基本循环语句 ==================for (var i = 0; i < 5; i++) {console.log(i);}console.log(i);//这个大家应该很快就知道了,012345================== setTimeout与var语句的for循环 ==================for (var i

【数据结构初阶】链表分类与双向带头循环链表接口实现

文章目录 1. 链表的分类2. 双向带头循环链表接口实现2. 1 结点声明2. 2 创建链表节点2. 3 初始化链表2. 4 打印链表2. 5 尾插2. 6 判空2. 7 尾删2. 8 头插2. 9 头删2. 10 查找2. 11 在指定位置删除与插入2. 12 销毁 3. 链表接口测试4. 单链表与双链表5. 顺序表与链表 1. 链表的分类 链表的结构非常多样,以下情况组合