Java CountDownLatch完成異步回調(diào)實例詳解

更新時間：2017年03月22日 14:43:22 投稿：lqh

這篇文章主要介紹了Java CountDownLatch完成異步回調(diào)實例詳解的相關(guān)資料,需要的朋友可以參考下

Java CountDownLatch完成異步回調(diào)實例詳解

實例代碼：

public class AsyncDemo {

  private static void doSomeTask() {
    System.out.println("Hello World");
  }

  private static void onCompletion() {
    System.out.println("All tasks finished");
  }

  public static void main(String[] args) {
    ExecutorService executor = Executors.newCachedThreadPool();
    final CountDownLatch latch = new CountDownLatch(2);

    executor.execute(new Task(latch));
    executor.execute(new Task(latch));

    executor.execute(() -> {
      try {
        latch.await();
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      onCompletion();
    });
    executor.shutdown();
  }

  private static class Task implements Runnable {

    /**
     * CountDownLatch 是JDK提供的一個簡單的線程監(jiān)測工具
     * 基于簡單的計數(shù)，調(diào)用countDown()方法表明當前線程已經(jīng)終止
     * 在監(jiān)測線程中調(diào)用await()方法,該方法會一直掛起直到所有其它線程終止
     */
    private final CountDownLatch latch;

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

    @Override
    public void run() {
      try {
        doSomeTask();
      } catch (Exception e) {
        e.printStackTrace();
      } finally {
        latch.countDown();
      }
    }
  }
}

這里有兩點需要補充：

1.如果你是用main方法啟動的線程，這種調(diào)用方法是沒有問題的，JDK會確保所有線程都終止以后main方法才退出。但是如果main方法不是異步任務的啟動者（如JUnit,Spring,Tomcat），一旦啟動之后laucher將會失去對線程的控制。如在JUnit中l(wèi)aucher提交完任務后就會被認為所有過程已完成，其它線程會被強行終止。

2.正因為如此，請根據(jù)環(huán)境使用正確的Executor。比如，在web環(huán)境中，應該選用tomcat（或Spring）管理的線程池作為Executor，這樣才能確保web應用對于異步任務的整個生命周期具有控制權(quán)；如果你選用JDK的線程池有什么后果呢？任務也許可以正常執(zhí)行，當一旦你終止web-app，正在執(zhí)行的異步線程并不會被正常kill掉，并由此造成內(nèi)存泄漏或其它不可預見的后果。

感謝閱讀，希望能幫助到大家，謝謝大家對本站的支持！

您可能感興趣的文章: