首页 > 代码库 > java中CyclicBarrier简单入门使用
java中CyclicBarrier简单入门使用
一个同步辅助类，它允许一组线程互相等待，直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中，这些线程必须不时地互相等待，此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用，所以称它为循环 的 barrier。
CyclicBarrier 支持一个可选的 Runnable 命令，在一组线程中的最后一个线程到达之后（但在释放所有线程之前），该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态，此屏障操作 很有用。 在java JDK中是这样解释的，在我们日常开发中常常需要一组线程结束之后，再接着进行，我们就需要考虑使用这个类了。
执行之后打印如下结果：
线程 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 到达都到齐，走吧
<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);
}
}
}
java中CyclicBarrier简单入门使用
声明：以上内容来自用户投稿及互联网公开渠道收集整理发布，本网站不拥有所有权，未作人工编辑处理，也不承担相关法律责任，若内容有误或涉及侵权可进行投诉： 投诉/举报 工作人员会在5个工作日内联系你，一经查实，本站将立刻删除涉嫌侵权内容。