首页 > 代码库 > CyclicBarrier分析与实例
CyclicBarrier分析与实例
一,介绍
?CyclicBarrier是一个保持多个线程共享同一个状态的工具类。也就是说在多线程环境下,可以通过设定某一个状态来达到线程之间的同步。这个类有两个有参构造方法,分别是CyclicBarrier(int n)和CyclicBarrier(int n, Runnable r)。第一个构造方法的意思是指给这个类设置等待点到多少时才执行在run方法中调用await方法之后的操作;第二个构造器的Runnable可以看作一个等待点的狼烟,狼烟是什么,是一种信号,也就是说,在等待线程达到n这个数量之后,会开始执行run方法中调用await方法之后的代码,而在调用这些代码前,会先放狼烟,然后再执行那些代码。
这个类在多线程统计数据时还是很有用的。但是要注意,如果你的线程数量总是达不到设置的n的数量,那么这时,操作将被阻塞,即await方法后面的代码总是不能执行。
二,例子
package test; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.Random; import java.util.concurrent.BrokenBarrierException; import java.util.concurrent.CyclicBarrier; public class CyclicBarrrierTest { static int count = 0; static List<Integer> data= http://www.mamicode.com/Collections.synchronizedList(new ArrayList());>
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。