CyclicBarrier
程序员文章站
2022-04-20 16:13:24
...
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/
谢谢您的赞助,我会做的更好!
下一篇: 想要微笑美臀吗?这坏习惯不要有
推荐阅读
-
Java中CyclicBarrier的用法分析
-
CountDownLatch(闭锁)、Semaphore(信号量)、CyclicBarrier
-
Java并发系列之CyclicBarrier源码分析
-
并发编程(二)—— CountDownLatch、CyclicBarrier和Semaphore
-
线程屏障CyclicBarrier实现原理
-
死磕 java同步系列之CyclicBarrier源码解析——有图有真相
-
JUC——线程同步辅助工具类(Semaphore,CountDownLatch,CyclicBarrier)
-
【JDK源码分析】通过源码分析CyclicBarrier
-
Java并发编程(CyclicBarrier)实例详解
-
java.util.concurrent常用类(CountDownLatch,Semaphore,CyclicBarrier,Future)