javaさく

1547 ワード

http://blog.csdn.net/lmc_wy/articale/detail/7866863

五人で終点まで走れば、みんなビールを飲むことができます。しかし、終点まで来ない人がいると飲めません。ここでは同時にスタートするように要求していません。
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

public class Beer {

	public static void main(String[] args) {
		final int count = 5;
		final CyclicBarrier barrier = new CyclicBarrier(count, new Runnable() {
			@Override
			public void run() {
				System.out.println("drink beer!");
			}
		});

		// they do not have to start at the same time...
		for (int i = 0; i < count; i++) {
			new Thread(new Worker(i, barrier)).start();
		}
	}

}

class Worker implements Runnable {
	final int id;
	final CyclicBarrier barrier;

	public Worker(final int id, final CyclicBarrier barrier) {
		this.id = id;
		this.barrier = barrier;
	}

	@Override
	public void run() {
		try {
			System.out.println(this.id + "starts to run !");
			Thread.sleep((long) (Math.random() * 10000));
			System.out.println(this.id + "arrived !");
			this.barrier.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (BrokenBarrierException e) {
			e.printStackTrace();
		}
	}
}