标签：style blog class code java tar ext width strong get string
一个小队去登山，每位队员登山的速度不同。山上有几个集合点，在每一集合点处，先到达的队员只有等后面的队员全部到达集合点后才能继续向下一个集合点出发。
JDK1.5提供的CyclicBarrier模拟了这种情况。每一个线程相当于一个登山队员，CyclicBarrier相当于山上的集合点。只有等所有线程都执行到了CyclicBarrier后才可以继续向下执行。
CyclicBarrier允许一组线程互相等待，直到到达某个公共屏障点 (common
barrier point)。在涉及一组固定大小的线程的程序中，这些线程必须不时地互相等待，此时 CyclicBarrier 很有用。因为该 barrier
在释放等待线程后可以重用，所以称它为循环 的 barrier。
CyclicBarrier有两个构造器：
CyclicBarrier(int
parties)：创建一个新的CyclicBarrier，它将在给定数量的参与者（线程）处于等待状态时启动，但它不会在启动barrier时执行预定义的操作。
CyclicBarrier(int parties, Runnable
barrierAction)：创建一个新的CyclicBarrier，它将在给定数量的参与者（线程）处于等待状态时启动，并在启动 barrier
时执行给定的屏障操作，该操作由最后一个进入 barrier 的线程执行。
在程序某一处调用CyclicBarrier对象的await()方法可以设置公共屏障点。调用getNumberWaiting()方法返回当前在屏障处等待的参与者数目。
见下面程序
- public class CyclicBarrierDemo {
-
- public static void main(String[] args) {
-
-
- ExecutorService pool = Executors.newCachedThreadPool();
-
- final CyclicBarrier barrier = new CyclicBarrier(3);
-
-
- for(int i = 0; i < 3; i++){
- Runnable target = new Runnable() {
- @Override
- public void run() {
- try{
- Thread.sleep((long)(Math.random()*10000));
- System.out.println(Thread.currentThread().getName() +
- "-即将到达集合点1，当前有" + (barrier.getNumberWaiting()+1) + "个线程已到达，" +
- (barrier.getNumberWaiting() == 2?"都到齐了，继续出发":"等待中..."));
-
- barrier.await();
-
- Thread.sleep((long)(Math.random()*10000));
- System.out.println(Thread.currentThread().getName() +
- "-即将到达集合点2，当前有" + (barrier.getNumberWaiting()+1) + "个线程已到达，" +
- (barrier.getNumberWaiting() == 2?"都到齐了，继续出发":"等待中..."));
-
- barrier.await();
-
- Thread.sleep((long)(Math.random()*10000));
- System.out.println(Thread.currentThread().getName() +
- "-即将到达集合点3，当前有" + (barrier.getNumberWaiting()+1) + "个线程已到达，" +
- (barrier.getNumberWaiting() == 2?"都已到达":"等待中..."));
-
- barrier.await();
- }catch(Exception e){
- e.printStackTrace();
- }
- }
- };
-
- pool.execute(target);
- }
- pool.shutdown();
- }
-
- }
运行程序
看到3个线程都到达屏障点后才继续向下执行。
Java多线程与并发库高级应用之公共屏障点CyclicBarrier,码迷,mamicode.com
Java多线程与并发库高级应用之公共屏障点CyclicBarrier
标签：style blog class code java tar ext width strong get string
原文地址：http://www.cnblogs.com/sfce/p/3701636.html
