您的位置:首页 > 编程语言 > Java开发

java使用CountDownLatch实现线程顺序执行

2017-07-15 13:04 357 查看
package concurrent;

import java.util.concurrent.CountDownLatch;

public class ThreadSequence {

   public static void main(String[] args) throws InterruptedException {
       final CountDownLatch latch1 = new CountDownLatch(1);
       Thread t1 = new Thread(new FirstThread(latch1));
       final CountDownLatch latch2 = new CountDownLatch(1);
       Thread t2 = new Thread(new SecondThread(latch2));
       final CountDownLatch latch3 = new CountDownLatch(1);
       Thread t3 = new Thread(new ThirdThread(latch3));
       
       t1.start();
       latch1.await();
       t2.start();
       latch2.await();
       t3.start();
       latch3.await();
       System.out.println("the main thread is End...");
   }
}

class FirstThread implements Runnable{

  private final CountDownLatch latch;

   public FirstThread(CountDownLatch latch) {
       this.latch = latch;
   }

   public void run() {
       System.out.println("the first thread is running!");
   
       
       SleepUtils.sleep(5);
       System.out.println("FirstThread----------->count=" + latch.getCount());
       latch.countDown();
   }
}

class SecondThread implements Runnable{

  private final CountDownLatch latch;

   public SecondThread(CountDownLatch latch) {
       this.latch = latch;
   }
   public void run() {
       System.out.println("the second thread is running!");
       
       SleepUtils.sleep(2);
       System.out.println("SecondThread----------->count=" + latch.getCount());
       latch.countDown();
   }
}
class ThirdThread implements Runnable{

  private final CountDownLatch latch;

   public ThirdThread(CountDownLatch latch) {
       this.latch = latch;
   }

   public void run() {
       System.out.println("the third thread is running!");
    
       System.out.println("ThirdThread----------->count=" + latch.getCount());
       latch.countDown();
   }
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: 
相关文章推荐