@Test
public void testCountDownLauch(){
ExecutorService executorService = Executors.newFixedThreadPool(4);
final CountDownLatch order = new CountDownLatch(1);
final CountDownLatch answer = new CountDownLatch(4);
for(int i=0;i<4;i++){
Runnable runnable = new Runnable() {
@Override
public void run() {
try {
System.out.println("线程:"+Thread.currentThread().getName()+"等待执行");
order.await();//等待order执行countDown方法
System.out.println("线程:"+Thread.currentThread().getName()+"出发");
Thread.sleep((long) (Math.random() * 10000));
System.out.println("线程:" + Thread.currentThread().getName() + "执行结束");
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
answer.countDown();//计数器减一
}
}
};
executorService.execute(runnable);
}
//order执行countDown方法;线程开始执行
try {
Thread.sleep((long) (Math.random() * 10000));
System.out.println("线程执行命令即将发出");
order.countDown();
System.out.println("线程执行命令发出");
answer.await();//等待answer里面的线程执行结束,等待answer执行countDown方法;
System.out.println("所有线程执行结束");
System.out.println("主线程执行");
} catch (InterruptedException e) {
e.printStackTrace();
}
executorService.shutdown();
}
在使用join()中,多个线程只有在执行完毕之后才能被解除阻塞,而在CountDownLatch中,线程可以在任何时候任何位置调用countdown方法减少计数,通过这种方式,我们可以更好地控制线程的解除阻塞,而不是仅仅依赖于连接线程的完成。
如果侵权,联系本人删除