首页 > 代码库 > 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());>


CyclicBarrier分析与实例