Java使用CyclicBarrier

public class TestUtil {
	private static final int USE_NUM = 5;
	
	private CyclicBarrier barrier = new CyclicBarrier(USE_NUM, new Runnable() {
		@Override
		public void run() {
			System.out.println("整齐划一");
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
	});

	void start() {
		for (int i = 0; i < USE_NUM; i++) {
			new Thread(new Worker()).start();
		}
	}


	public static void main(String[] args) {
		new TestUtil().start();
	}

	public class Worker implements Runnable {
		@Override
		public void run() {
			try {
				for (int i = 0; i < 5; i++) {
					System.out.println(Thread.currentThread() + "执行" + i);
					//等待所有线程执行完毕
					barrier.await();
				}
			} catch (InterruptedException e) {
				e.printStackTrace();
			} catch (BrokenBarrierException e) {
				e.printStackTrace();
			}
		}
	}
}