Java JUC工具类--CyclicBarrier

CyclicBarrier：栅栏的概念，多线程的进行阻塞，等待某一个临界值条件满足后，同时执行
类比：每个线程代表一个跑步运动员，当运动员都准备好后，才一起出发，只要有一个人没有准备好，大家都等待

package com.example.core.juc;import java.util.Random;
import java.util.concurrent.*;public class UseCyclicBarrier {static class Runner implements Runnable{private String name;private CyclicBarrier cyclicBarrier;public Runner(String name,CyclicBarrier cyclicBarrier){this.name = name;this.cyclicBarrier = cyclicBarrier;}@Overridepublic void run(){try {System.out.println("运动员：" +this.name +", 进行准备工作");Thread.sleep(1000*(new Random()).nextInt(10));//模拟每一个运动员的休整时间System.out.println("运动员："+this.name +",准备OK！");this.cyclicBarrier.await();//只有所有运动员都休整完毕，才会同时启动}catch(InterruptedException e){e.printStackTrace();}catch(BrokenBarrierException e){e.printStackTrace();}System.out.println("运动员："+this.name+"，Go！Go！Go！");}}public static void main(String[] args) {CyclicBarrier cyclicBarrier = new CyclicBarrier(3);//线程池ExecutorService executorService = Executors.newFixedThreadPool(3);executorService.submit(new Thread(new Runner("张三",cyclicBarrier)));executorService.submit(new Thread(new Runner("里斯",cyclicBarrier)));executorService.submit(new Thread(new Runner("王武",cyclicBarrier)));executorService.shutdown();//关闭线程池}
}
/*
运动员：张三, 进行准备工作
运动员：王武, 进行准备工作
运动员：里斯, 进行准备工作
运动员：张三,准备OK！
运动员：里斯,准备OK！
运动员：王武,准备OK！
运动员：张三，Go！Go！Go！
运动员：王武，Go！Go！Go！
运动员：里斯，Go！Go！Go！
*/

适用于如下情况，外部请求调用的函数由四部分组成，分别是1、2、3和4，第4部分需要1、2和3的结果作为输入值，并且他们将数据传给4的时间是不同的，所以4需要等待最慢的结果（短板效应），因此，最慢的也是我们今后的突破口

Java JUC工具类--CyclicBarrier相关推荐

Java JUC工具类--ForkJoin
ForkJoin Fork/Join框架是JAVA7提供的一个用于并行执行任务的框架,是一个把大任务分割成若干个小任务,最终汇总每个小任务结果后得到大任务结果的框架 Fork/Join中两个重要的类 ...
Java JUC工具类--Future
Future模式,也是非常经典的设计模式,这种模式主要就利用空间换时间的概念,也就是说异步执行(需要开启一个新的线程) 在互联网高并发的应用服务中,我们随处可见这种理念和代码,主要就是使用了这种模式 ...
Java JUC工具类--Semaphore
Semaphore 在Semaphore信号量非常适合高并发访问限制,新系统在上线之前,要对系统的访问量进行评估,评估是经过以往的经验.数据.历年的访问量,已经推广力度进行一个合理的评估当然评估标准 ...
Java JUC工具类--Master-Worker
Master-Worker Master-Worker模式是常用的并行计算模式.它的核心思想是系统由两类进程协作工作:Master进程和Worker进程 Master负责接收和分配任务,Worker负 ...
Java JUC工具类--Exchanger
Exchanger Exchanger用于进行线程间的数据交换,它提供一个同步点,在这个同步点,两个线程可以交换彼此的数据两个线程通过exchange方法交换数据,如果一个线程先执行exchange ...
Java JUC工具类--CountDownLatch
CountDownLatch:用于监听某些初始化操作,并且线程进行阻塞,等初始化执行完毕后,通知主线程继续工作执行 package com.example.core.juc;import java.u ...
Java并发工具类--CyclicBarrier详解
CyclicBarrier允许一组线程在到达某个栅栏点(common barrier point)互相等待,直到最后一个线程到达栅栏点,栅栏才会打开,处于阻塞状态的线程恢复继续执行. 举例举个例子来 ...
Java并发工具类（闭锁CountDownLatch）
并发工具类系列: Java并发工具类(闭锁CountDownLatch) Java并发工具类(栅栏CyclicBarrier) Java并发工具类(信号量Semaphore) 闭锁是一种同步工具类,可 ...
彻底理解Java并发：Java并发工具类
本篇内容包括:Java 并发工具类的介绍.使用方式与 Demo,包括了 CountDownLatch(线程计数器).CyclicBarrier(回环栅栏).Semaphore(信号量) 以及 Exch ...

Java JUC工具类--CyclicBarrier

Java JUC工具类--CyclicBarrier相关推荐

最新文章

热门文章