`

java.util.concurrent 之五:倒计数的锁

    博客分类:
  • Java
阅读更多
    从名字可以看出,CountDownLatch是一个倒数计数的锁,当倒数到0时触发事件,也就是开锁,其他人就可以进入了。在一些应用场合中,需要等待某个条件达到要求后才能做后面的事情;同时当线程都完成后也会触发事件,以便进行后面的操作。


CountDownLatch最重要的方法是countDown()和await(),前者主要是倒数一次,后者是等待倒数到0,如果没有到达0,就只有阻塞等待了。

一个CountDownLatch实例是不能重复使用的,也就是说它是一次性的,锁一经被打开就不能再关闭使用了,如果想重复使用,请考虑使用CyclicBarrier。

下面的例子简单的说明了CountDownLatch的使用方法,模拟了100米赛跑,10名选手已经准备就绪,只等裁判一声令下。当所有人都到达终点时,比赛结束。

同样,线程池需要显式shutdown。
package test;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class TestCountDownLatch{
	public static void main(String[] args) throws InterruptedException{
		//开始的倒数锁
		final CountDownLatch begin=new CountDownLatch(1);
		//结束的倒数锁
		final CountDownLatch end=new CountDownLatch(10);
		//10名选手
		final ExecutorService exec=Executors.newFixedThreadPool(10);
		
		for(int index=0; index<10;index++){
			final int NO=index + 1;//Cannot refer to a non-final variable NO inside an inner class defined in a different method
			Runnable run=new Runnable(){
				public void run(){
					try{
						begin.await();//一直阻塞
						Thread.sleep((long)(Math.random() * 10000));
						System.out.println("No." + NO + " arrived");
					}catch(InterruptedException e){
					}finally{
						end.countDown();
					}
				}
			};
			exec.submit(run);
		}
		System.out.println("Game Start");
		begin.countDown();
		end.await();
		System.out.println("Game Over");
		exec.shutdown();
	}
}


可能的结果:
Game Start
No.4 arrived
No.6 arrived
No.8 arrived
No.5 arrived
No.10 arrived
No.3 arrived
No.2 arrived
No.7 arrived
No.1 arrived
No.9 arrived
Game Over


分享到:
评论

相关推荐

Global site tag (gtag.js) - Google Analytics