JDK5.0新特性系列---11.5.3线程 同步装置之CyclicBarrier
import java.util.Random;
import java.util.concurrent.CyclicBarrier;
/**
* CyclicBarrier维持一个计数器,与CountDownLatch不同的是,等待这个CyclicBarrier的线程必须等到计数器的某个值时,才可以继续.
* CyclicBarrier就像它名字的意思一样,可看成是个障碍,所有的线程必须到齐后才能一起通过这个障碍.
*/
/**
* 本实例实现一个数组相邻元素的加法,一个线程给数组的第一个元素赋值,然后等待其它线程给数组第二个元素赋值,然后将第一个元素和第二个元素相加.
*/
/**
* CyclicBarrier的关键技术点如下:
* 1.构造CyclicBarrier对象时,需要指定计数器的目标值,计数器的初始值为0.
* 还可以在构造方法中带一个 Runnable参数,表示当计数器到达目标值是,在等待CyclicBarrier的线程被唤醒之前,指定该Runnable任务.
* 2.CyclicBarrier的await方法使当前线程进入等待状态,同时将计数器值加1,当计数器到达目标值时,当前线程被唤醒.
*/
public class CyclicBarrierTest {
public static class ComponentThread implements Runnable{
CyclicBarrier barrier;//计数器
int ID;//组件
int[] array; //数据数组
public ComponentThread(CyclicBarrier barrier,int[] array,int ID){
this.barrier = barrier;
this.ID = ID;
this.array = array;
}
public void run(){
try{
//Random的nextInt(int n)方法返回一个[0,n)范围内的随机数
array[ID] = new Random().nextInt(100);
System.out.println("Componet " + ID + " sleep...");
barrier.await();
System.out.println("Componet " + ID + " awaked...");
//计算数据数组中的当前值和后续值
int result = array[ID] + array[ID + 1];
System.out.println("Component " + ID + " result: " + result);
}catch(Exception ex){
}
}
}
/**测试CyclicBarrier的用法*/
public static void testCyclicBarrier(){
final int[] array = new int[3];
CyclicBarrier barrier = new CyclicBarrier(2,new Runnable(){
public void run(){
System.out.println("testCyclicBarrier run...");
array[2] = array[0] + array[1];
}
});
//启动线程
new Thread(new ComponentThread(barrier,array,0)).start();
new Thread(new ComponentThread(barrier,array,1)).start();
}
public static void main(String... args){
CyclicBarrierTest.testCyclicBarrier();
}
}
本文转自远哥博客园博客,原文链接:http://www.cnblogs.com/taven/archive/2011/12/17/2291476.html,如需转载请自行联系原作者
JDK5.0新特性系列---11.5.3线程 同步装置之CyclicBarrier相关推荐
- JDK5.0新特性系列---11.5.4线程 同步装置之Exchanger
/** * Exchanger让两个线程互换信息 * 实例模拟服务生和顾客,服务生往空杯子中倒水,顾客从装满水的杯子中喝水,然后互换杯子,服务生接着倒水,顾客接着喝水. */ /** * 使用Exch ...
- JDK5.0新特性系列---11.4线程 Condition
import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util ...
- JDK5.0新特性系列---目录
JDK5.0新特性系列---目录 JDK5.0新特性系列---1.自动装箱和拆箱 JDK5.0新特性系列---2.新的for循环 JDK5.0新特性系列---3.枚举类型 JDK5.0新特性系列--- ...
- JDK5.0新特性--可变参数
2019独角兽企业重金招聘Python工程师标准>>> /*** 可变参数*/ public class VariableParamater {/*** 统计2个或多个数的和*/pu ...
- JDK5.0新特性之:泛型
文/陈刚 2005-11-09 一.前言 泛型这个词在现在的JAVA挺时髦,光从字面上你是无法知道它代表些什么东东的,所以我们还是不要从字面去理解,而是从一些实例去了解它吧. 二.泛型之前的日子 JD ...
- C# 3.0新特性系列(1):隐含类型局部变量
一.隐含类型局部变量简介 在C#3.0中增加了很多新的语言特性,如果有一个局部变量被声明为var,这个声明被视为隐含类型局部变量声明,然后由编译器根据局部变量初始化表达式来推断变量的类型.如下面的声明 ...
- jdk5.0新特性—— 枚举
为什么80%的码农都做不了架构师?>>> 目录 1.枚举的简介 2.枚举的api的操作 3.项目中枚举的实例 ===================== ...
- C#3.0 新特性系列(6) Extension Methods
You can use Extension Methods to add methods to existing types without declaring a new derived type, ...
- Android5.0,6.0,7.0,8.0新特性整理
背景 Android5.0(Android Lollipop)是谷歌公司2014年10月发布的全新安卓系统,至今已经两年多.然而由于国产手机对安卓ROM的深度定制或修改,以及手机厂商.芯片制造商.运营 ...
最新文章
- 结构光系统标定方法详解
- Android Lanuch 的资料汇总
- Verilog Design's Tips
- php获取谷歌地图api接口,谷歌地图 API 开发之信息窗口
- easy and hard things
- java 以什么开头_判断字符串以什么开头
- 使用PaddleFluid和TensorFlow实现图像分类网络SE_ResNeXt | 文末超大福利
- 110. Balanced Binary Tree 平衡二叉树
- 解决redis-cli连接时出现Could not connect to Redis at 127.0.0.1:6379: Connection refused
- Java 分割、合并byte数组
- 软件开发有哪些规范和标准_深圳APP软件开发的流程是什么?
- HDU 1233 还是畅通工程(最小生成树)
- ITextSharp生成PDF
- linux c 网络事件 通知,深入理解Linux网络技术内幕—通知链
- java设置时间_怎么用java设置系统时间?
- Nginx 禁止国外 IP 访问网站
- 极大似然估计法的理解
- USB接口类型及引脚定义-usb1.0,usb2.0,usb3.0,Type-c
- 学信网-账号被注销解决方法
- [备查]使用 SPQuery 查询 Person or Group 字段