并发编程工具之二:CyclicBarrier 用法
2017-11-23 15:40
741 查看
CyclicBarrier 用法
从字面上这个类可以理解为环形屏障,它可以协同多个线程,让多个线程在这个屏障前等待。当所有线程都达到这个屏障时,再一起执行后续的动作。如下图:三个线程各有一个barrier.await,那么任何一个线程执行到barrier.await时就会进入阻塞状态进行等待,知道三个线程都达到了barrier.await才会同时从await返回,就需后续的工作。此外,如果在构造CyclicBarrier时设置了Runnable实现,那么最后一个到barrier.await的线程会执行Runnable的run方法。
结合例子看一下:
public class TCyclicBarrierestDemo { private static int count = 10; public static void main(String[] args) { CyclicBarrier cb = new CyclicBarrier(count, new Runnable() { @Override public void run() { System.out.println("Runnable实现方法运行了");//当所有线程到达“屏障”时执行 } }); for (int i = 0; i < count; i++) { new Thread(new WorkerThread(cb)).start(); } } } class WorkerThread implements Runnable{ CyclicBarrier barrier; public WorkerThread(CyclicBarrier b){ this.barrier = b; } @Override public void run() { try{ System.out.println("线程到达屏障,开始等待"); barrier.await();//线程在这里等待,直到所有线程都到达“屏障”。 System.out.println("线程"+Thread.currentThread().getName()+" 开始后续工作"); }catch(Exception e){ e.printStackTrace(); } } } 运行结果: 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 线程到达屏障,开始等待 Runnable实现方法运行了 线程Thread-8 开始后续工作 线程Thread-5 开始后续工作 线程Thread-1 开始后续工作 线程Thread-6 开始后续工作 线程Thread-9 开始后续工作 线程Thread-4 开始后续工作 线程Thread-0 开始后续工作 线程Thread-7 开始后续工作 线程Thread-2 开始后续工作 线程Thread-3 开始后续工作
相关文章推荐
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程深入学习——CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- java并发编程之CyclicBarrier
- Java7并发编程--3.3、CyclicBarrier在集合点同步
- Java并发编程:CountDownLatch、CyclicBarrier和 Semaphore
- Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解
- Java中的并发工具CountDownLatch、CyclicBarrier、Semapphore使用详解
- java并发编程学习:如何等待多个线程执行完成后再继续后续处理(synchronized、join、FutureTask、CyclicBarrier)
- 【Java并发编程】之二十二:并发新特性—障碍器CyclicBarrier(含代码)
- Java并发编程:CountDownLatch、CyclicBarrier和 Semaphore
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程之CyclicBarrier
- java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- 【Java并发编程】之二十二:并发新特性—障碍器CyclicBarrier(含代码)(r)
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程之栅栏(CyclicBarrier)详解
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore
- Java并发编程:CountDownLatch、CyclicBarrier和Semaphore