本文是一篇文章对网络的研究摘要,感谢您的无私分享。
CyclicBarrier 类有一个整数初始值,此值表示将在同一点同步的线程数量。当当中一个线程到达确定点,它会调用await() 方法来等待其它线程。当线程调用这种方法,CyclicBarrier堵塞线程进入休眠直到其它线程到达。当最后一个线程调用CyclicBarrier
类的await() 方法,它唤醒全部等待的线程并继续运行它们的任务。
注意比較CountDownLatch和CyclicBarrier:
1.CountDownLatch的作用是同意1或N个线程等待其它线程完毕运行;而CyclicBarrier则是同意N个线程相互等待。
2.CountDownLatch的计数器无法被重置。CyclicBarrier的计数器能够被重置后使用,因此它被称为是循环的barrier。
package chapter3;import java.util.concurrent.CyclicBarrier;public class TestCyclicBarrier { private static final int THREAD_NUM = 5; public static class WorkerThread implements Runnable{ CyclicBarrier barrier; public WorkerThread(CyclicBarrier b){
this.barrier = b;
} @Override
public void run() {
// TODO Auto-generated method stub
try{
System.out.println("ID:"+Thread.currentThread().getId()+"Worker's waiting");
//线程在这里等待,直到全部线程都到达barrier。barrier.await();
System.out.println("ID:"+Thread.currentThread().getId()+" Working");
}catch(Exception e){
e.printStackTrace();
}
} } /**
*
* <p>
* </p>
* @author zhangjunshuai
* @date 2014-9-29 上午11:27:36
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
CyclicBarrier cb = new CyclicBarrier(THREAD_NUM, new Runnable() {
//当全部线程到达barrier时运行
@Override
public void run() {
// TODO Auto-generated method stub
System.out.println("Inside Barrier"); }
}); for(int i=0;i<THREAD_NUM;i++){
new Thread(new WorkerThread(cb)).start();
}
}}
版权声明:本文博主原创文章,博客,未经同意不得转载。