欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java线程并发cyclicbarrier类使用示例

程序员文章站 2024-02-22 14:20:58
复制代码 代码如下:package com.yao; import java.util.random;import java.util.concurrent.cyclic...

复制代码 代码如下:

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();
 }
}