cyclicbarrier

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的想法。

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

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

cyclicbarrier

cyclicbarrier_Java并发– CyclicBarrier示例相关推荐

  1. Java并发– CyclicBarrier示例

    Java中的CyclicBarrier是JDK 5中java.util.Concurrent包中引入的同步器,以及其他并发实用程序(如Counting Semaphore , BlockingQueu ...

  2. PHP使用文件锁解决高并发问题示例

    PHP使用文件锁解决高并发问题示例 参考文章: (1)PHP使用文件锁解决高并发问题示例 (2)https://www.cnblogs.com/lxwphp/p/8949518.html (3)htt ...

  3. (原创)使用TimeStamp控制并发问题[示例]-.cs脚本

    TimeStamp.aspx.cs代码(C#),已调试通过:   1using System;   2using System.Collections;   3using System.Compone ...

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

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

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

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

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

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

  7. php 文件锁 重发请求,PHP使用文件锁解决高并发问题示例

    本文实例讲述了PHP使用文件锁解决高并发问题.分享给大家供大家参考,具体如下: 新建一个.txt文件,文件中什么都不用写. [一].阻塞(等待)模式:(只要有其他进程已经加锁文件,当前进程会一直等其他 ...

  8. golang并发官方示例

    文章目录 Goroutines Channels Buffered Channels Range and Close Select fatal error: all goroutines are as ...

  9. java 取整型的低八位_Java 基础(十五)并发工具包 concurrent

    本文目录: java.util.concurrent - Java 并发包简介 阻塞队列 BlockingQueue 数组阻塞队列 ArrayBlockingQueue 延迟队列 DelayQueue ...

最新文章

  1. dataset的去重计数 g2_去互联网公司面试,面试官问我SpringCloud,附答案
  2. 原创,真正解决iframe高度自适应的问题.兼容各浏览器
  3. snmp linux arm,Net-SNMP的交叉编译 for ARM64
  4. 关于Linux网卡调优之:RPS (Receive Packet Steering)
  5. 【英语学习】【WOTD】accolade 释义/词源/示例
  6. 交钱赎“人”!B站500万粉UP主被黑客勒索,腾讯都表示无解
  7. 使用memcachedclientXmemcached与Spring整合
  8. freeswitch被叫忙处理
  9. 查询linux安装了哪种中文,linux 安装 中文字体
  10. dk 7 linux x64.rpm,linux x64 Java/JDK 11下载 jdk-11.0.7_linux-x64_bin.rpm官方镜像版
  11. 什么是智能dns解析
  12. Dev-C++ 一直提示源文件未编译,原因及解决办法
  13. Lucas–Kanade method(LK光流法)
  14. 多重继承--读松本行弘的程序世界
  15. 捋一捋Python中的Dict(下)
  16. 大家都在用哪些OKR管理工具?
  17. 20145240 《信息安全系统设计基础》第六周同学问题总结
  18. 在word 页眉插入章编号+标题
  19. 帝国cms cj1.php,帝国cms源码中常用函数所在位置
  20. 【Matlab学习手记】csv和xlsx格式互转

热门文章

  1. 什么是 CAS 机制
  2. Java工程师必备技能
  3. 搭建ssh框架的步骤
  4. 《四世同堂》金句摘抄(九)
  5. React功能界面的组件化编码流程
  6. 去掉字符串后面所有的0 去掉字符串前面或后面的0;
  7. php array分组,php数组分组简单例子
  8. centos8启动zk集群失败:zk Error contacting service. It is probably not running.
  9. MySQL8.0: Serialized Dictionary Information(SDI) 浅析
  10. 使用互联网了解的两个月里_我两个月来对Quarkus的了解