JUC之CyclicBarrier循环避障
举例说明CyclicBarrier循环避障:
游乐园水上划船，规定5个人划一艘船,如果人不够,那么就需要等待，直到凑齐5个人了,才允许开始。也就是说,5个人一波5个人一波。每一波都是同一时间开始玩的。
即：循环避障保证了多个线程在准确的同一刻开始。
注:CyclicBarrier循环避障适用于多线程必须同时开始的情景。
代码示例
import java.util.Date;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
/**
* 循环避障 示例
*
* @author JustryDeng
* @date 2018/10/17 19:39
*/
public class CyclicBarrierDemo {
/** 设置循环避障数 */
private static CyclicBarrier cyclicBarrier = new CyclicBarrier(5);
public static void main(String[] args) throws InterruptedException {
// -> 创建可缓存长线程池
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 1; i <= 10; i++) {
Thread.sleep(1000);
// 使用lambel表达式简单实现Runnable接口的run方法
executorService.execute(() -> {
try {
System.out.println(new Date() + "线程" + Thread.currentThread().getName() + "准备就绪!");
// 设置避障点
cyclicBarrier.await();
System.out.println(new Date() + "线程" + Thread.currentThread().getName() + "开始运行!");
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
});
}
// 关闭线程池
executorService.shutdown();
}
}运行主函数，输出结果为:
注:await(long timeout, TimeUnit unit)方法可以设置一个超时时间,如果等待超时了,那么会抛出异常;其它同组等待的线程
就知道不需要等了，没有结果的。
注:CyclicBarrier常用场景有(举例说明):
1.双十一00:00分秒杀
2.准点抢票
3.跑分测试
……
注:本人多线程一栏的文章大多为简记、后续时间充裕了再回头进行丰富。