Java中的CyclicBarrier是JDK 5中java.util.Concurrent包中引入的同步器,以及其他并发实用程序(如Counting Semaphore , BlockingQueue , ConcurrentHashMap等)。CyclicBarrier与CountDownLatch类似,我们在上一篇文章中看到了它,它允许多个线程等待彼此(障碍),然后继续。 CoundDownLatch和CyclicBarrier之间的区别也是Java中一个非常流行的多线程面试问题 。 CyclicBarrier是并发程序的自然要求,因为一旦单个任务完成,它就可以用于执行任务的最后一部分。 等待彼此到达屏障的所有线程都称为方,使用要等待的方数初始化CyclicBarrier,然后通过调用CyclicBarrier.await()方法来彼此等待线程,这是Java中的阻塞方法,直到所有线程都阻塞或各方调用await()。 通常,调用await()会喊出Thread正在等待屏障。 await()是一个阻塞调用,但可以被其他线程超时或中断。 在此Java并发性教程中,我们将看到CyclicBarrier的简单示例,在该示例上,三个线程将互相等待,然后再继续操作。
Java中 CountDownLatch CyclicBarrier 之间的区别
在上一篇文章中,我们了解了如何使用CountDownLatch来实现多个相互等待的线程 。 如果您查看CyclicBarrier,它也做同样的事情,但是有不同之处,一旦计数达到零,您将无法重用 CountDownLatch ,而您可以通过调用reset()方法重用CyclicBarrier来将Barrier重置为其初始状态。 这意味着CountDownLatch适用于一次事件,例如应用程序启动时间,而CyclicBarrier可以用于周期性事件,例如同时计算大问题的解决方案等。如果您想了解有关Java中线程和并发性的更多信息,也可以查看我有关何时在Java中使用Volatile变量以及Java 如何同步的文章 。
Java中的 CyclicBarrier –示例
这是Java中CyclicBarrier的一个简单示例,在该示例中,我们使用3个方初始化了CyclicBarrier,这意味着为了越过障碍,3个线程需要调用await()方法。 每个线程都在短时间内调用await方法,但是直到所有3个线程都到达障碍为止,它们才继续进行,一旦所有线程到达障碍,障碍都获得代理,并且每个线程从此处开始执行。 通过以下CyclicBarrier示例在Java中的输出,可以很清楚地看到它:
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.logging.Level;
import java.util.logging.Logger;/**
* Java program to demonstrate how to use CyclicBarrier in Java. CyclicBarrier is a
* new Concurrency Utility added in Java 5 Concurrent package.
*
* @author Javin Paul
*/public class CyclicBarrierExample {//Runnable task for each thread
private static class Task implements Runnable {private CyclicBarrier barrier;public Task(CyclicBarrier barrier) {
this.barrier = barrier;
}@Override
public void run() {
try {
System.out.println(Thread.currentThread().getName() + " is waiting on barrier");
barrier.await();
System.out.println(Thread.currentThread().getName() + " has crossed the barrier");
} catch (InterruptedException ex) {
Logger.getLogger(CyclicBarrierExample.class.getName()).log(Level.SEVERE, null, ex);
} catch (BrokenBarrierException ex) {
Logger.getLogger(CyclicBarrierExample.class.getName()).log(Level.SEVERE, null, ex);
}
}
}public static void main (String args[]) {//creating CyclicBarrier with 3 parties i.e. 3 Threads needs to call await()
final CyclicBarrier cb = new CyclicBarrier(3, new Runnable(){
@Override
public void run(){
//This task will be executed once all thread reaches barrier
System.out.println("All parties are arrived at barrier, lets play");
}
});//starting each of thread
Thread t1 = new Thread(new Task(cb), "Thread 1");
Thread t2 = new Thread(new Task(cb), "Thread 2");
Thread t3 = new Thread(new Task(cb), "Thread 3");t1.start();
t2.start();
t3.start();}
}

输出:

Thread 1 is waiting on barrier
Thread 3 is waiting on barrier
Thread 2 is waiting on barrier
All parties are arrived at barrier, lets play
Thread 3 has crossed the barrier
Thread 1 has crossed the barrier
Thread 2 has crossed the barrier
何时 在Java中 使用 CyclicBarrier
鉴于CyclicBarrier的性质, 与Java 7的fork-join框架类似,实现map reduce任务非常方便,在Java 7中 ,将大任务分解为较小的部分,并完成需要从单个小任务输出的任务,例如要计算印度的人口,您可以有4个线程来计算北,南,东和西的人口,完成后它们可以互相等待,当最后一个线程完成任务时,主线程或任何其他线程可以从每个区域中添加结果并打印总人口。 您可以在Java中使用CyclicBarrier:
1)实现多人游戏,直到所有玩家都加入后才能开始。
2)通过将其分解为较小的单个任务来执行冗长的计算,通常要实施Map reduce技术。
Java CyclicBarrier的 重点
1.一旦所有线程到达barrier,CyclicBarrier即可执行完成任务,可以在创建CyclicBarrier时提供。
2.如果用3个参与者初始化了CyclicBarrier,则意味着3个线程需要调用await方法来打破该障碍。
3. 线程将在await()上阻塞 ,直到各方到达障碍,另一个线程中断或等待超时为止。
4.如果另一个线程中断正在等待屏障的线程,它将抛出BrokernBarrierException,如下所示:
java.util.concurrent.BrokenBarrierException
at java.util.concurrent.CyclicBarrier.dowait(CyclicBarrier.java:172)
at java.util.concurrent.CyclicBarrier.await(CyclicBarrier.java:327)
5. CyclicBarrier .reset()将Barrier置于其初始状态,正在等待或尚未达到屏障的其他线程将以java.util.concurrent.BrokenBarrierException终止。
以上就是Java中带有示例的CyclicBarrier。 我们还看到了Java中CountDownLatch和CyclicBarrier之间的区别,并且了解了一些可以在Java并发代码中使用CyclicBarrier的想法。

参考: Javarevisited博客上的JCG合作伙伴 Javin Paul提供的Java 5中的CyclicBarrier示例–并发教程 。

翻译自: https://www.javacodegeeks.com/2012/08/java-concurrency-cyclicbarrier-example.html

Java并发– CyclicBarrier示例相关推荐

  1. cyclicbarrier_Java并发– CyclicBarrier示例

    cyclicbarrier Java中的CyclicBarrier是JDK 5中在java.util.Concurrent包上引入的同步器,以及其他并发实用程序,例如Counting Semaphor ...

  2. java线程本地变量_Java并发编程示例(九):本地线程变量的使用

    这篇文章主要介绍了Java并发编程示例(九):本地线程变量的使用,有时,我们更希望能在线程内单独使用,而不和其他使用同一对象启动的线程共享,Java并发接口提供了一种很清晰的机制来满足此需求,该机制称 ...

  3. java 并发实例_java一些常用并发工具示例

    最近把<java并发编程实战>-Java Consurrency in Practice 重温了一遍,把书中提到的一些常用工具记录于此: 一.闭锁(门栓)- CountDownLatch ...

  4. java一些常用并发工具示例

    最近把<java并发编程实战>-Java Consurrency in Practice 重温了一遍,把书中提到的一些常用工具记录于此: 一.闭锁(门栓)- CountDownLatch ...

  5. java并发编程代码示例_java并发编程之同步器代码示例

    java并发编程之同步器代码示例 发布时间:2020-09-08 16:53:41 来源:脚本之家 阅读:58 作者:Blessing_H 同步器是一些使线程能够等待另一个线程的对象,允许它们协调动作 ...

  6. Java并发编程系列学习_CountDownLatch倒计时器CyclicBarrier循环栅栏

    一.倒计时器CountDownLatch 在多线程协作完成业务功能时,有时候需要等待其他多个线程完成任务之后,主线程才能继续往下执行业务功能,在这种的业务场景下,通常可以使用Thread类的join方 ...

  7. Java并发编程之CyclicBarrier详解

    简介 栅栏类似于闭锁,它能阻塞一组线程直到某个事件的发生.栅栏与闭锁的关键区别在于,所有的线程必须同时到达栅栏位置,才能继续执行.闭锁用于等待事件,而栅栏用于等待其他线程. CyclicBarrier ...

  8. 【Java 并发编程】线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )

    文章目录 前言 一.线程池示例 二.newCachedThreadPool 线程池示例 三.newFixedThreadPool 线程池示例 三.newSingleThreadExecutor 线程池 ...

  9. Java并发编程:CountDownLatch、CyclicBarrier和Semaphore

    2019独角兽企业重金招聘Python工程师标准>>> Java并发编程:CountDownLatch.CyclicBarrier和Semaphore 在java 1.5中,提供了一 ...

最新文章

  1. 高性能Linux服务器运维实战,《高性能Linux服务器构建实战》笔记
  2. Spring事务--笔记
  3. 06:甲流疫情死亡率
  4. ECCV 2020《TRRNet: Tiered Relation Reasoning for Compositional Visual Question Answering》论文笔记
  5. Java中intern()方法的作用
  6. 公钥加密以及混合加密
  7. 如何实现场景切换的java_JavaFX + Scene Builder如何切换场景(JavaFX + Scene Builder how switch scene)...
  8. django解决:ModuleNotFoundError: No module named ‘django.core.urlresolvers‘
  9. php微信公众号测试号token配置失败,微信公众号Token配置失败解决办法
  10. 如何在 NVIDIA GPU、CUDA 和 cuDNN 中使用 OpenCV 的“dnn”模块
  11. Altium designer-PCB设计基础笔记
  12. CAD图纸的保存格式DWG DWF DXF互相转换是怎么操作的?
  13. 同城门户同城分类信息网站源码+小程序端+49款插件
  14. 计算机ppt实训报告总结,计算机实训总结模板
  15. Android类库常用类库一览
  16. 崩溃!因对领导不满前网管离职后远程入侵服务器,致诊疗系统瘫痪!
  17. nodejs 运行后报错 Error: Couldn‘t find preset “es2015“ relative to directory
  18. 2021年全球住宅电梯收入大约1534.2百万美元,预计2028年达到1957.3百万美元
  19. 安徽农商行计算机类笔试考什么,2019安徽农商行社会招聘:笔试考什么?如何复习? 【附带笔试模拟题】...
  20. 【win10】文件重命名怎么改不了文件格式/改不了后缀/想要更改文件后缀/改变文件类型

热门文章

  1. 自定义类加载器(ClassLoader + URLClassLoader)
  2. jvm 垃圾收集算法_JVM垃圾收集和优化
  3. jmeter进行性能测试_使用JMeter进行性能测试
  4. spring api层打包_Spring项目的按层打包已过时
  5. spring多个视图解析器_在Spring中配置多个View解析器
  6. tomcat默认连接数_Tomcat的默认连接器
  7. Spring核心注释
  8. java开发人员_Java 8:开发人员怎么看?
  9. 使用Spock 1.2简化对遗留应用程序的集成测试
  10. grails框架_Play和Grails Java框架的优缺点