Java并发编程之栅栏(CyclicBarrier)实例介绍
栅栏类似闭锁,但是它们是有区别的.
1.闭锁用来等待事件，而栅栏用于等待其他线程.什么意思呢?就是说闭锁用来等待的事件就是countDown事件,只有该countDown事件执行后所有之前在等待的线程才有可能继续执行;而栅栏没有类似countDown事件控制线程的执行,只有线程的await方法能控制等待的线程执行.
2.CyclicBarrier强调的是n个线程，大家相互等待，只要有一个没完成，所有人都得等着。
场景分析:10个人去春游,规定达到一个地点后才能继续前行.代码如下
importjava.util.concurrent.BrokenBarrierException; importjava.util.concurrent.CyclicBarrier;
classCyclicBarrierWorkerimplementsRunnable{ privateintid; privateCyclicBarrierbarrier;
publicCyclicBarrierWorker(intid,finalCyclicBarrierbarrier){ this.id=id; this.barrier=barrier; }
@Override publicvoidrun(){ //TODOAuto-generatedmethodstub try{ System.out.println(id+"thpeoplewait"); barrier.await();//大家等待最后一个线程到达 }catch(InterruptedException|BrokenBarrierExceptione){ //TODOAuto-generatedcatchblock e.printStackTrace(); } } }
publicclassTestCyclicBarrier{ publicstaticvoidmain(String[]args){ intnum=10; CyclicBarrierbarrier=newCyclicBarrier(num,newRunnable(){ @Override publicvoidrun(){ //TODOAuto-generatedmethodstub System.out.println("goontogether!"); } }); for(inti=1;i<=num;i++){ newThread(newCyclicBarrierWorker(i,barrier)).start(); } } }