5.6 CountDownLatch
CountDownLatch
类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。比如有一个任务A,它要等待其他4个任务执行完毕之后才能执行,此时就可以利用CountDownLatch来实现这种功能了。
CountDownLatch类只提供了一个构造器:
public CountDownLatch(int count) { }; //参数count为计数值
然后下面这3个方法是CountDownLatch类中最重要的方法:
//调用await()方法的线程会被挂起,它会等待直到count值为0才继续执行 public void await() throws InterruptedException { }; //和await()类似,只不过等待一定的时间后count值还没变为0的话就会继续执行 public boolean await(long timeout, TimeUnit unit) throws InterruptedException { }; //将count值减1 public void countDown() { }; |
下面看一个例子大家就清楚CountDownLatch的用法了:
public class Test { public static void main(String[] args) { final CountDownLatch latch = new CountDownLatch(2); new Thread(){ public void run() { try { System.out.println("子线程"+Thread.currentThread().getName()+"正在执行"); Thread.sleep(3000); System.out.println("子线程"+Thread.currentThread().getName()+"执行完毕"); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } }; }.start(); new Thread(){ public void run() { try { System.out.println("子线程"+Thread.currentThread().getName()+"正在执行"); Thread.sleep(3000); System.out.println("子线程"+Thread.currentThread().getName()+"执行完毕"); latch.countDown(); } catch (InterruptedException e) { e.printStackTrace(); } }; }.start(); try { System.out.println("等待2个子线程执行完毕..."); latch.await(); System.out.println("2个子线程已经执行完毕"); System.out.println("继续执行主线程"); } catch (InterruptedException e) { e.printStackTrace(); } } }
执行结果:
线程Thread-0正在执行 线程Thread-1正在执行 等待2个子线程执行完毕... 线程Thread-0执行完毕 线程Thread-1执行完毕 2个子线程已经执行完毕 继续执行主线程
在上面的例子中,主线程就是调用线程,主线中设置了CountDownLatch的值为2,并启动两个线程,每个线程执行完成之后将CountDownLatch减1,最后主线程中调用了latch.await()。此时主线程就会等到CountDownLatch值为0时才能继续往下执行。也是说,必须等到两个线程执行完成之后,才能执行。需要注意的是,如果CountDownLatch设置的值大于2的话,那么主线程就会一直等待下去,因为CountDownLatch的值即使减去2次,还是大于0,主线程只能一直等待。
如果不想一直等待下去,可以调用其
public boolean await(long timeout, TimeUnit unit) |
返回true表示指定时间内所有线程执行完,返回false表示指定时间内,所有线程没有执行完。