JAVA中CyclicBarrier(关卡)
2015-06-27 15:26
501 查看
CyclicBarrier 类似于我们前面看到的CountDownLatch.但是有以下两点不同:
1:CountDownLatch 是当状态达到后即当计数器为零,所有线程通过后CountDownLatch不可再用。而CyclicBarrier 可以当状态达到后,所有线程通过后即可重复使用。
2:CountDownLatch 等待的是事件。CyclicBarrier 等待的是线程.
这里解释下等待事件和线程的区别.
由于CountDownLatch 存在countDown()方法。即对计数器减去1
假设我们有如下代码:CountDownLatch latch = new CountDownLatch(5);
我们在一个线程中对countDown()调用了5次。那么这个CountDownLatch的计数器就减为零。
然后等待的线程就可以通过了。
CyclicBarrier 一直等待指定数量的线程是否全部已经到达await()点了。如果全部达到,则“开闸”释放所有线程继续执行。
我们来看下CyclicBarrier 的方法:
再看下它的构造器:
举例说明下CyclicBarrier的几种用法:
1.重复使用
1:CountDownLatch 是当状态达到后即当计数器为零,所有线程通过后CountDownLatch不可再用。而CyclicBarrier 可以当状态达到后,所有线程通过后即可重复使用。
2:CountDownLatch 等待的是事件。CyclicBarrier 等待的是线程.
这里解释下等待事件和线程的区别.
由于CountDownLatch 存在countDown()方法。即对计数器减去1
假设我们有如下代码:CountDownLatch latch = new CountDownLatch(5);
我们在一个线程中对countDown()调用了5次。那么这个CountDownLatch的计数器就减为零。
然后等待的线程就可以通过了。
CyclicBarrier 一直等待指定数量的线程是否全部已经到达await()点了。如果全部达到,则“开闸”释放所有线程继续执行。
我们来看下CyclicBarrier 的方法:
再看下它的构造器:
举例说明下CyclicBarrier的几种用法:
1.重复使用
package com.asiainfo.concurrent;
/**
* @author fansh
*/
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;
public class CyclicBarrierTest {
public static void main(String[] args) {
CyclicBarrier barrier = new CyclicBarrier(5);
System.out.println(barrier.getParties());
for(int i=0;i<5;i++){
BarrierThread thread = new BarrierThread(barrier);
thread.start();
}
}
}
class BarrierThread extends Thread{
private CyclicBarrier barrier;
public BarrierThread(CyclicBarrier barrier){
this.barrier=barrier;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName()+"first point running! ...........");
try {
barrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"first point finished!.............");
try {
Thread.sleep(1000);
} catch (InterruptedException e1) {
e1.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"second point running! ...........");
try {
barrier.await();
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName()+"second point finished!.............");
}
}
相关文章推荐
- Java并发学习笔记(15)信号量(Semaphore) 关卡((2)CyclicBarrier)
- java CyclicBarrier(关卡)详解
- java CyclicBarrier原理和示例
- java多线程解说【拾陆】_并发工具类:CyclicBarrier
- Java并发之工具类CyclicBarrier
- (九)java多线程之CyclicBarrier
- java多线程之CyclicBarrier
- JAVA多线程之——CyclicBarrier
- Java多线程(八)之Semaphore、CountDownLatch、CyclicBarrier、Exchanger
- java并发包线程同步 - CountDownLatch与CyclicBarrier比较学习
- Java CyclicBarrier 设置线程等待点
- Java并发之CountDownLatch、CyclicBarrier和Semaphore
- Java多线程系列--“JUC锁”10之 CyclicBarrier原理和示例
- java.util.concurrent.CyclicBarrier
- 【死磕Java并发】—- J.U.C之并发工具类:CyclicBarrier
- 谈谈java中CyclicBarrier的用法
- java多线程之闭锁(Latch)和栅栏(CyclicBarrier)
- think in java笔记: java.util.concurrent.CyclicBarrier
- Java的CyclicBarrier(循环屏障)
- java并发之同步辅助类(Semphore、CountDownLatch、CyclicBarrier、Phaser、Exchanger)