java高並發系列 – 第31天：獲取執行緒執行結果，這6種方法你都知道？

  • 2019 年 10 月 3 日
  • 筆記

這是java高並發系列第31篇。

環境：jdk1.8。

java高並發系列已經學了不少東西了，本篇文章，我們用前面學的知識來實現一個需求：

在一個執行緒中需要獲取其他執行緒的執行結果，能想到幾種方式？各有什麼優缺點？

結合這個需求，我們使用6種方式，來對之前學過的知識點做一個回顧，加深記憶。

方式1：Thread的join()方法實現

程式碼：

package com.itsoku.chat31;    import java.sql.Time;  import java.util.concurrent.*;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo1 {      //用於封裝結果      static class Result<T> {          T result;            public T getResult() {              return result;          }            public void setResult(T result) {              this.result = result;          }      }        public static void main(String[] args) throws ExecutionException, InterruptedException {          System.out.println(System.currentTimeMillis());          //用於存放子執行緒執行的結果          Result<Integer> result = new Result<>();          //創建一個子執行緒          Thread thread = new Thread(() -> {              try {                  TimeUnit.SECONDS.sleep(3);                  result.setResult(10);              } catch (InterruptedException e) {                  e.printStackTrace();              }          });          thread.start();          //讓主執行緒等待thread執行緒執行完畢之後再繼續，join方法會讓當前執行緒阻塞          thread.join();            //獲取thread執行緒的執行結果          Integer rs = result.getResult();          System.out.println(System.currentTimeMillis());          System.out.println(System.currentTimeMillis() + ":" + rs);      }  }

輸出：

1566733162636  1566733165692  1566733165692:10

程式碼中通過join方式阻塞了當前主執行緒，當thread執行緒執行完畢之後，join方法才會繼續執行。

join的方式，只能阻塞一個執行緒，如果其他執行緒中也需要獲取thread執行緒的執行結果，join方法無能為力了。

關於join()方法和執行緒更詳細的使用，可以參考：執行緒的基本操作

方式2：CountDownLatch實現

程式碼：

package com.itsoku.chat31;    import java.util.concurrent.*;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo2 {      //用於封裝結果      static class Result<T> {          T result;            public T getResult() {              return result;          }            public void setResult(T result) {              this.result = result;          }      }        public static void main(String[] args) throws ExecutionException, InterruptedException {          System.out.println(System.currentTimeMillis());          CountDownLatch countDownLatch = new CountDownLatch(1);          //用於存放子執行緒執行的結果          Demo1.Result<Integer> result = new Demo1.Result<>();          //創建一個子執行緒          Thread thread = new Thread(() -> {              try {                  TimeUnit.SECONDS.sleep(3);                  result.setResult(10);              } catch (InterruptedException e) {                  e.printStackTrace();              }finally {                  countDownLatch.countDown();              }          });          thread.start();          //countDownLatch.await()會讓當前執行緒阻塞，當countDownLatch中的計數器變為0的時候，await方法會返回          countDownLatch.await();            //獲取thread執行緒的執行結果          Integer rs = result.getResult();          System.out.println(System.currentTimeMillis());          System.out.println(System.currentTimeMillis() + ":" + rs);      }  }

輸出：

1566733720406  1566733723453  1566733723453:10

上面程式碼也達到了預期效果，使用CountDownLatch可以讓一個或者多個執行緒等待一批執行緒完成之後，自己再繼續；CountDownLatch更詳細的介紹見：JUC中等待多執行緒完成的工具類CountDownLatch，必備技能

方式3：ExecutorService.submit方法實現

程式碼：

package com.itsoku.chat31;    import java.util.concurrent.*;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo3 {      public static void main(String[] args) throws ExecutionException, InterruptedException {          //創建一個執行緒池          ExecutorService executorService = Executors.newCachedThreadPool();          System.out.println(System.currentTimeMillis());          Future<Integer> future = executorService.submit(() -> {              try {                  TimeUnit.SECONDS.sleep(3);              } catch (InterruptedException e) {                  e.printStackTrace();              }              return 10;          });          //關閉執行緒池          executorService.shutdown();          System.out.println(System.currentTimeMillis());          Integer result = future.get();          System.out.println(System.currentTimeMillis() + ":" + result);      }  }

輸出：

1566734119938  1566734119989  1566734122989:10

使用ExecutorService.submit方法實現的，此方法返回一個Future，future.get()會讓當前執行緒阻塞，直到Future關聯的任務執行完畢。

相關知識：

  1. JAVA執行緒池，這一篇就夠了
  2. JUC中的Executor框架詳解1
  3. JUC中的Executor框架詳解2

方式4：FutureTask方式1

程式碼：

package com.itsoku.chat31;    import java.util.concurrent.*;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo4 {      public static void main(String[] args) throws ExecutionException, InterruptedException {          System.out.println(System.currentTimeMillis());          //創建一個FutureTask          FutureTask<Integer> futureTask = new FutureTask<>(() -> {              try {                  TimeUnit.SECONDS.sleep(3);              } catch (InterruptedException e) {                  e.printStackTrace();              }              return 10;          });          //將futureTask傳遞一個執行緒運行          new Thread(futureTask).start();          System.out.println(System.currentTimeMillis());          //futureTask.get()會阻塞當前執行緒，直到futureTask執行完畢          Integer result = futureTask.get();          System.out.println(System.currentTimeMillis() + ":" + result);      }  }

輸出：

1566736350314  1566736350358  1566736353360:10

程式碼中使用FutureTask實現的，FutureTask實現了Runnable介面，並且內部帶返回值，所以可以傳遞給Thread直接運行，futureTask.get()會阻塞當前執行緒，直到FutureTask構造方法傳遞的任務執行完畢，get方法才會返回。關於FutureTask詳細使用，請參考：JUC中的Executor框架詳解1

方式5：FutureTask方式2

程式碼：

package com.itsoku.chat31;    import java.util.concurrent.ExecutionException;  import java.util.concurrent.FutureTask;  import java.util.concurrent.TimeUnit;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo5 {      public static void main(String[] args) throws ExecutionException, InterruptedException {          System.out.println(System.currentTimeMillis());          //創建一個FutureTask          FutureTask<Integer> futureTask = new FutureTask<>(() -> 10);          //將futureTask傳遞一個執行緒運行          new Thread(() -> {              try {                  TimeUnit.SECONDS.sleep(3);              } catch (InterruptedException e) {                  e.printStackTrace();              }              futureTask.run();          }).start();          System.out.println(System.currentTimeMillis());          //futureTask.get()會阻塞當前執行緒，直到futureTask執行完畢          Integer result = futureTask.get();          System.out.println(System.currentTimeMillis() + ":" + result);      }  }

輸出：

1566736319925  1566736319970  1566736322972:10

創建了一個FutureTask對象，調用futureTask.get()會阻塞當前執行緒，子執行緒中休眠了3秒，然後調用futureTask.run();當futureTask的run()方法執行完畢之後，futureTask.get()會從阻塞中返回。

注意：這種方式和方式4的不同點。

關於FutureTask詳細使用，請參考：JUC中的Executor框架詳解1

方式6：CompletableFuture方式實現

程式碼：

package com.itsoku.chat31;    import java.util.concurrent.CompletableFuture;  import java.util.concurrent.ExecutionException;  import java.util.concurrent.FutureTask;  import java.util.concurrent.TimeUnit;    /**   * 跟著阿里p7學並發，微信公眾號：javacode2018   */  public class Demo6 {      public static void main(String[] args) throws ExecutionException, InterruptedException {          System.out.println(System.currentTimeMillis());          CompletableFuture<Integer> completableFuture = CompletableFuture.supplyAsync(() -> {              try {                  TimeUnit.SECONDS.sleep(3);              } catch (InterruptedException e) {                  e.printStackTrace();              }              return 10;          });          System.out.println(System.currentTimeMillis());          //futureTask.get()會阻塞當前執行緒，直到futureTask執行完畢          Integer result = completableFuture.get();          System.out.println(System.currentTimeMillis() + ":" + result);      }  }

輸出：

1566736205348  1566736205428  1566736208429:10

CompletableFuture.supplyAsync可以用來非同步執行一個帶返回值的任務，調用completableFuture.get()

會阻塞當前執行緒，直到任務執行完畢，get方法才會返回。

關於CompletableFuture更詳細的使用見：JUC中工具類CompletableFuture，必備技能

java高並發系列目錄

  1. 第1天:必須知道的幾個概念
  2. 第2天:並發級別
  3. 第3天:有關並行的兩個重要定律
  4. 第4天:JMM相關的一些概念
  5. 第5天:深入理解進程和執行緒
  6. 第6天:執行緒的基本操作
  7. 第7天:volatile與Java記憶體模型
  8. 第8天:執行緒組
  9. 第9天：用戶執行緒和守護執行緒
  10. 第10天:執行緒安全和synchronized關鍵字
  11. 第11天:執行緒中斷的幾種方式
  12. 第12天JUC:ReentrantLock重入鎖
  13. 第13天:JUC中的Condition對象
  14. 第14天:JUC中的LockSupport工具類，必備技能
  15. 第15天：JUC中的Semaphore（訊號量）
  16. 第16天：JUC中等待多執行緒完成的工具類CountDownLatch，必備技能
  17. 第17天：JUC中的循環柵欄CyclicBarrier的6種使用場景
  18. 第18天：JAVA執行緒池，這一篇就夠了
  19. 第19天：JUC中的Executor框架詳解1
  20. 第20天：JUC中的Executor框架詳解2
  21. 第21天：java中的CAS，你需要知道的東西
  22. 第22天：JUC底層工具類Unsafe，高手必須要了解
  23. 第23天：JUC中原子類，一篇就夠了
  24. 第24天：ThreadLocal、InheritableThreadLocal（通俗易懂）
  25. 第25天：掌握JUC中的阻塞隊列
  26. 第26篇：學會使用JUC中常見的集合，常看看！
  27. 第27天：實戰篇，介面性能提升幾倍原來這麼簡單
  28. 第28天：實戰篇，微服務日誌的傷痛，一併幫你解決掉
  29. 第29天：高並發中常見的限流方式
  30. 第30天：JUC中工具類CompletableFuture，必備技能

阿里p7一起學並發，公眾號：路人甲java，每天獲取最新文章！

VirMach 便宜 VPS

QNews

QNews