并发编程-CyclicBarrier屏障

上一篇 <<<Semaphore信号量
下一篇 >>>线程池

• 屏障---CyclicBarrier
• new CyclicBarrier(5); 需要等待的线程总数
• cyclicBarrier.await();等待线程数达到屏障数，然后多个线程一起执行后面的操作

测试代码

CyclicBarrier cyclicBarrier=new CyclicBarrier(3);
for (int i = 0; i < 5; i++) {
    Writer writer = new Writer(cyclicBarrier);
    writer.start();
}

public void run() {
    System.out.println(System.currentTimeMillis()+" 线程" + Thread.currentThread().getName() + ",正在写入数据");
    try {
        Thread.sleep(3000);
    } catch (Exception e) {

    }
    System.out.println(System.currentTimeMillis()+" 线程" + Thread.currentThread().getName() + ",写入数据成功.....");

    try {
        cyclicBarrier.await();
    } catch (Exception e) {
    }
    System.out.println(System.currentTimeMillis()+" 线程" + Thread.currentThread().getName() + "所有线程执行完毕..........");
}

相关文章链接：
<<<多线程基础
<<<线程安全与解决方案
<<<锁的深入化
<<<锁的优化
<<<Java内存模型(JMM)
<<<Volatile解决JMM的可见性问题
<<<Volatile的伪共享和重排序
<<<CAS无锁模式及ABA问题
<<<Synchronized锁
<<<Lock锁
<<<AQS同步器
<<<Condition
<<<CountDownLatch同步计数器
<<<Semaphore信号量
<<<线程池
<<<并发队列
<<<Callable与Future模式
<<<Fork/Join框架
<<<Threadlocal
<<<Disruptor框架
<<<如何优化多线程总结