CyclicBarrier使用

       CyclicBarrier，它维护一个计数器，与CountDownLatch不同的是，等待这个CyclicBarrier的线程必须等到计数器到达 某个值时，才可以继续。CyclicBarrier就像它名字的意思一样，可看成是个障碍，所有的线程必须到齐后才能一起通过这个障碍。

package com.supr;

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class Second {

	public static void main(String[] args) {

		//屏障点
		final CyclicBarrier b = new CyclicBarrier(10, new Runnable() {
			@Override
			public void run() {
				System.out.println("人到齐，开吃....");
			}
		});
		
		for (int i = 0; i < 10; i++) {

			Runnable run = new Runnable() {
				@Override
				public void run() {
					System.out.println(Thread.currentThread().getName() + "赶来吃饭...");
					try {
						b.await();
					} catch (InterruptedException e) {
						e.printStackTrace();
					} catch (BrokenBarrierException e) {
						e.printStackTrace();
					}
				}
			};

			Thread t = new Thread(run);
			t.start();
		}
	}
}

 打印信息：

Thread-0赶来吃饭...
Thread-1赶来吃饭...
Thread-2赶来吃饭...
Thread-3赶来吃饭...
Thread-4赶来吃饭...
Thread-5赶来吃饭...
Thread-6赶来吃饭...
Thread-7赶来吃饭...
Thread-8赶来吃饭...
Thread-9赶来吃饭...
人到齐，开吃....

 

 

       构造CyclicBarrier对象时，需要指定计数器的目标值，计数器的初始值为0.还可以在构造方法中带一个Runnable参数，表示当计数器到达目标值时，在等待CyclicBarrier的线程被唤醒之前，指定该Runnable任务。
       CyclicBarrier的await方法使当前线程进入等待状态，计数器加1，当计数器到达目标值时，当前线程被唤醒。

       CyclicBarrier可循环使用。

 

参考：http://www.blogjava.net/xylz/archive/2010/07/12/325913.html

          http://www.blogjava.net/kissyan4916/articles/307091.html