首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >java中CyclicBarrier简单入门使用

java中CyclicBarrier简单入门使用

作者头像
用户5166556
发布于 2019-04-16 06:31:12
发布于 2019-04-16 06:31:12
48000
代码可运行
举报
运行总次数:0
代码可运行

一个同步辅助类,它允许一组线程互相等待,直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中,这些线程必须不时地互相等待,此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用,所以称它为循环 的 barrier。

CyclicBarrier 支持一个可选的 Runnable 命令,在一组线程中的最后一个线程到达之后(但在释放所有线程之前),该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态,此屏障操作 很有用。 在java JDK中是这样解释的,在我们日常开发中常常需要一组线程结束之后,再接着进行,我们就需要考虑使用这个类了。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
 执行之后打印如下结果:
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
线程 pool-1-thread-1即将到达线程集合点1,已有  1 到达继续等候
线程 pool-1-thread-3即将到达线程集合点1,已有  2 到达继续等候
线程 pool-1-thread-2即将到达线程集合点1,已有  3 到达都到齐,走吧
线程 pool-1-thread-2即将到达线程集合点2,已有  1 到达继续等候
线程 pool-1-thread-1即将到达线程集合点2,已有  2 到达继续等候
线程 pool-1-thread-3即将到达线程集合点2,已有  3 到达都到齐,走吧
线程 pool-1-thread-3即将到达线程集合点3,已有  1 到达继续等候
线程 pool-1-thread-1即将到达线程集合点3,已有  2 到达继续等候
线程 pool-1-thread-2即将到达线程集合点3,已有  3 到达都到齐,走吧
代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
<pre name="code" class="java">import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


public class CyclicBarrierTest {

	/**
	 * @param args
	 */
	public static void main(String[] args) {
         ExecutorService ThreadPool = Executors.newCachedThreadPool();
         final CyclicBarrier cyclic = new CyclicBarrier(3);
         for(int i=0;i<3;i++){
        	 Runnable runnable = new Runnable() {
				
				@Override
				public void run() {
                    try {
                    	Thread.sleep((long) (Math.random()*3000));
                    	System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点1,已有  " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候"));
						cyclic.await(); 
						Thread.sleep((long) (Math.random()*3000));
                    	System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点2,已有  " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候"));
						cyclic.await(); 
						Thread.sleep((long) (Math.random()*3000));
                    	System.out.println("线程 " + Thread.currentThread().getName() + "即将到达线程集合点3,已有  " + (cyclic.getNumberWaiting()+1) + " 到达" + (cyclic.getNumberWaiting()==2 ? "都到齐,走吧": "继续等候"));
						cyclic.await(); 
					} catch (InterruptedException e) {
						e.printStackTrace();
					} catch (BrokenBarrierException e) {
						e.printStackTrace();
					}					
				}
			};
			ThreadPool.execute(runnable);
         }
         
	}

}
代码语言:javascript
代码运行次数:0
运行
复制
本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2014年11月01日,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
JAVA多线程(一)
一个进程可以包含多个线程。多个线程可以并行,但是一个时间点只能有一个线程是运行状态。
JQ实验室
2022/02/09
1830
Java并发编程:Semaphore、CountDownLatch、CyclicBarrier
首先我们来实现一个功能:当我们启动一个系统的时候需要初始化许多数据,这时候我们可能需要启动很多线程来进行数据的初始化,只有这些系统初始化结束之后才能够启动系统。其实在Java的类库中已经提供了Semaphore、CountDownLatch、CyclicBarrier这3个类来帮我们实现这样类似的功能了。 一、信号灯 Semaphore Semaphore sp = new Semaphore(int permits) 接受一个整数型的参数,表示有几盏灯。线程可以通过semaphore.acquire()获
陈树义
2018/04/13
7350
同步组件CyclicBarrier源码解析
CyclicBarrier可以理解为Cyclic + Barrier, 可循环使用 + 屏障嘛。
烂猪皮
2023/09/04
1900
同步组件CyclicBarrier源码解析
CyclicBarrier 的使用
1.CyclicBarrier 字面意思是可循环(Cyclic)使用的屏障(Barrier)。它要做的事情是让一组线程到达一个屏障(同步点)时被阻塞,直到最后一个线程到达屏障时候,屏障才会开门。所有被屏障拦截的线程才会运行。
Java架构师必看
2021/11/29
3260
CyclicBarrier 的使用
CyclicBarrier和CountDownLatch的用法与区别
CyclicBarrier和CountDownLatch这两个工具都是在java.util.concurrent包下,并且平时很多场景都会使用到。
Java识堂
2021/09/06
1.8K0
【小家java】JUC并发编程工具之CountDownLatch(闭锁)、CyclicBarrier、Semaphore的使用
CountDownLatch:是一个同步工具类,用来协调多个线程之间的同步,或者说起到线程之间的通信(而不是用作互斥的作用)。
YourBatman
2019/09/03
6050
【小家java】JUC并发编程工具之CountDownLatch(闭锁)、CyclicBarrier、Semaphore的使用
CyclicBarrier介绍
这个类的中文意思是“循环栅栏”。大概的意思就是一个可循环利用的屏障。它的作用就是会让所有线程都等待完成后才会继续下一步行动。CyclicBarrier的计数器更像一个阀门,需要所有线程都到达,然后继续执行,计数器递增,提供reset功能,可以多次使用。
HLee
2021/10/15
5490
CyclicBarrier介绍
JUC 中 4 个常用的并发工具类
CountDownLatch是我目前使用比较多的类,CountDownLatch初始化时会给定一个计数,然后每次调用countDown() 计数减1,
张乘辉
2021/11/10
4180
Java并发之CyclicBarrier(在集合点同步)CyclicBarrier引入创建CyclicBarrier遇到CyclicBarrier之后休眠CyclicBarrier的回调线程Cycli
CyclicBarrier类是一个同步辅助类,类似于CountDownLatch,但远比CountDownLatch要强大。CyclicBarrier 的字面意思是可循环使用(Cyclic)的屏障(Barrier)。它要做的事情是,让一组线程到达一个屏障(也可以叫同步点)时被阻塞,直到最后一个线程到达屏障时,屏障才会开门,所有被屏障拦截的线程才会继续干活。就如下面这个图所示
desperate633
2018/08/22
3720
Java并发之CyclicBarrier(在集合点同步)CyclicBarrier引入创建CyclicBarrier遇到CyclicBarrier之后休眠CyclicBarrier的回调线程Cycli
Java多线程10 同步工具类CyclicBarrier
CyclicBarrier是一个同步工具类,它允许一组线程互相等待,直到达到某个公共屏障点。与CountDownLatch不同的是该barrier在释放线程等待后可以重用,所以它称为循环(Cyclic)的屏障(Barrier)。 CyclicBarrier支持一个可选的Runnable命令,在一组线程中的最后一个线程到达之后(但在释放所有线程之前),该命令只在每个屏障点运行一次。若再继续所有的参与线程之前更新共享状态,此屏蔽操作很有用。
玖柒的小窝
2021/10/19
9110
Java高并发必学--concurrent包
JDK1.5引入了java.util.concurrent包,里边很有多有用的组件,我们挑选一些来学习
用户7353950
2022/06/23
5310
线程同步辅助工具类
Java 并发编程是整个 Java 开发体系中最难以理解但也是最重要的知识点,也是各类开源分布式框架(如 ZooKeeper、Kafka、Spring Cloud、Netty 等)中各个并发组件实现的基础。J.U.C 并发包,即 java.util.concurrent 包,大大提高了并发性能,是 JDK 的核心工具包,是 JDK 1.5 之后,由 Doug Lea 实现并引入。而 AQS 被认为是 J.U.C 的核心。
BUG弄潮儿
2021/03/22
8430
JAVA并发编程系列(9)CyclicBarrier循环屏障原理分析
之前我们在系列(8)《CountDownLatch核心原理》,实现过拼团场景。但是CountDownLatch里调用countDown()方法后,线程还是可以继续执行后面的代码,没有真正的阻塞。
拉丁解牛说技术
2024/09/20
1660
并发相关工具
我们在并发编程中,经常会使用到一些工具来帮助我们控制线程。本章节就会对CountDownLatch、CyclicBarrier、Semaphore工具的应用进行简单的介绍。
胖虎
2020/12/22
5600
并发设计模式实战系列(16):屏障(Barrier)
今天为大家带来的是并发设计模式实战系列,第十六章屏障(Barrier),废话不多说直接开始~
摘星.
2025/05/20
1520
AQS、CountDownLatch、CyclicBarrier、Semaphore、Exchanger
在编程的竞技场中,多线程与并发是每一级大牛必备的技能!今天,就让我们深入了解Java并发武器库中的“五神兵”——AQS、CountDownLatch、CyclicBarrier、Semaphore、Exchanger的强大之处。他们如棋盘上的棋子,既能彼此协调,又能独当一面,解决了无数线程之问的冲突、同步与协作难题。
疯狂的KK
2024/06/04
1840
AQS、CountDownLatch、CyclicBarrier、Semaphore、Exchanger
Java并发之CountDownLatch、Semaphore和CyclicBarrier
JAVA并发包中有三个类用于同步一批线程的行为,分别是CountDownLatch、Semaphore和CyclicBarrier。
用户1212940
2022/04/13
2840
Java并发之CountDownLatch、Semaphore和CyclicBarrier
并发编程系列之CyclicBarrier用法简介
定义:协同指定数目的线程,让这些线程都在这个屏障前等待,直到所有的线程都到这个屏障前,再一起继续执行。线程执行完成后,这个屏障可以再次使用,因此被称之为循环屏障。
SmileNicky
2021/11/30
7990
CyclicBarrier 不就是比 CountDownLatch 多了个回环么?
" 看完 CountDownLatch 正准备表示一番,突然看到了一个 CyclicBarrier —— 回环屏障。沃特?回环还屏障?说比 CountDownLatch 要多一个回环,那咱可得瞧一瞧,看一看了! "
程序员小航
2020/11/23
4140
CyclicBarrier 不就是比 CountDownLatch 多了个回环么?
源码阅读之CyclicBarrier
源码阅读是基于JDK7,本篇主要涉及CyclicBarrier常用方法源码分析。文中代码若格式排版不对,可点击底部的阅读原文阅读。 1.概述 CyclicBarrier是一个同步辅助类,它允许一组线程互相等待,直到所有线程都到达某个公共屏障点(也可以叫同步点),即相互等待的线程都完成调用await方法,所有被屏障拦截的线程才会继续运行await方法后面的程序。在涉及一组固定大小的线程的程序中,这些线程必须不时地互相等待,此时CyclicBarrier很有用。因为该屏障点在释放等待线程后可以重用,所以称它为循
JavaQ
2018/04/04
6390
相关推荐
JAVA多线程(一)
更多 >
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档