public class CyclicBarrierTest {
//在初次的4个线程越过barrier状态后，又可以用来进行新一轮的使用。而CountDownLatch无法进行重复使用。
public static void main(String[] args) throws InterruptedException {
ExecutorService newFixedThreadPool = Executors.newFixedThreadPool(10);
int num = 5 ;
CyclicBarrier cyclicBarrier = new CyclicBarrier(num);
for (int i = 0; i < 5; i++) {
newFixedThreadPool.submit(new CyclicBarrierRunnable(cyclicBarrier));
}
System.out.println("==========end===1========"+System.currentTimeMillis());
Thread.sleep(5000);
for (int i = 0; i < 5; i++) {
newFixedThreadPool.submit(new CyclicBarrierRunnable(cyclicBarrier));
}
System.out.println("==========end===2========"+System.currentTimeMillis());
newFixedThreadPool.shutdown();
}
public static class CyclicBarrierRunnable implements Runnable{
private CyclicBarrier cyclicBarrier;
public CyclicBarrierRunnable(CyclicBarrier cyclicBarrier) {
this.cyclicBarrier = cyclicBarrier;
}
@Override
public void run() {
try {
cyclicBarrier.await();
Thread.sleep(1000);
System.out.println("====================="+System.currentTimeMillis());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}
}
捐助开发者
在兴趣的驱动下,写一个免费的东西，有欣喜，也还有汗水，希望你喜欢我的作品，同时也能支持一下。 当然，有钱捧个钱场（支持支付宝和微信 以及扣扣群），没钱捧个人场，谢谢各位。
个人主页：http://knight-black-bob.iteye.com/
谢谢您的赞助，我会做的更好！
