1 import java.util.concurrent.CountDownLatch; 2 import java.util.concurrent.ExecutorService; 3 import java.util.concurrent.Executors; 4 5 public class CountdownLatchTest1 { 6 7 public static void main(String[] args) { 8 ExecutorService service = Executors. newFixedThreadPool(3); 9 final CountDownLatch latch = new CountDownLatch(3); 10 for (int i = 0; i < 3; i++) { 11 Runnable runnable = new Runnable() { 12 13 @Override 14 public void run() { 15 try { 16 System. out.println("子线程" + Thread.currentThread().getName() + "开始执行"); 17 Thread. sleep((long) (Math. random() * 10000)); 18 System. out.println("子线程" + Thread.currentThread().getName() + "执行完成"); 19 latch.countDown(); // 当前线程调用此方法,则计数减一 20 } catch (InterruptedException e) { 21 e.printStackTrace(); 22 } 23 } 24 }; 25 service.execute(runnable); 26 } 27 28 try { 29 System. out.println("主线程" + Thread.currentThread().getName() + "等待子线程执行完成..." ); 30 latch.await(); // 阻塞当前线程,直到计时器的值为0 31 System. out.println("主线程" + Thread.currentThread().getName() + "开始执行..."); 32 } catch (InterruptedException e) { 33 e.printStackTrace(); 34 } 35 } 36 }
1 import java.util.concurrent.CountDownLatch; 2 import java.util.concurrent.ExecutorService; 3 import java.util.concurrent.Executors; 4 5 public class CountdownLatchTest2 { 6 7 public static void main(String[] args) { 8 ExecutorService service = Executors. newCachedThreadPool(); 9 final CountDownLatch cdOrder = new CountDownLatch(1); 10 final CountDownLatch cdAnswer = new CountDownLatch(4); 11 for (int i = 0; i < 4; i++) { 12 Runnable runnable = new Runnable() { 13 public void run() { 14 try { 15 System. out.println("选手" + Thread.currentThread().getName() + "正等待裁判发布口令"); 16 cdOrder.await(); 17 System. out.println("选手" + Thread.currentThread().getName() + "已接受裁判口令"); 18 Thread. sleep((long) (Math. random() * 10000)); 19 System. out.println("选手" + Thread.currentThread().getName() + "到达终点"); 20 cdAnswer.countDown(); 21 } catch (Exception e) { 22 e.printStackTrace(); 23 } 24 } 25 }; 26 service.execute(runnable); 27 } 28 try { 29 Thread. sleep((long) (Math. random() * 10000)); 30 31 System. out.println("裁判" + Thread.currentThread ().getName() + "即将发布口令" ); 32 cdOrder.countDown(); 33 System. out.println("裁判" + Thread.currentThread ().getName() + "已发送口令,正在等待所有选手到达终点" ); 34 cdAnswer.await(); 35 System. out.println("所有选手都到达终点" ); 36 System. out.println("裁判" + Thread.currentThread ().getName() + "汇总成绩排名" ); 37 } catch (Exception e) { 38 e.printStackTrace(); 39 } 40 service.shutdown(); 41 42 } 43 }