java线程并发cyclicbarrier类使用示例

package com.yao;

import java.util.random;
import java.util.concurrent.cyclicbarrier;

/**
 * cyclicbarrier类似于countdownlatch也是个计数器，
 * 不同的是cyclicbarrier数的是调用了cyclicbarrier.await()进入等待的线程数，
 * 当线程数达到了cyclicbarrier初始时规定的数目时，所有进入等待状态的线程被唤醒并继续。
 * cyclicbarrier就象它名字的意思一样，可看成是个障碍，
 * 所有的线程必须到齐后才能一起通过这个障碍。
 * cyclicbarrier初始时还可带一个runnable的参数，
 * 此runnable任务在cyclicbarrier的数目达到后，所有其它线程被唤醒前被执行。
 */
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 {
    array[id] = new random().nextint(100);
    system.out.println("component " + id + " generates: " + array[id]);
    // 在这里等待barrier处
    system.out.println("component " + id + " sleep...");
    barrier.await();
    system.out.println("component " + 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() {
   // 在所有线程都到达barrier时执行
   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();
 }
}