快捷導(dǎo)航

java通過Callable和Future來接收線程池的執(zhí)行結(jié)果

更新時間：2019年08月16日 09:24:00 作者：逍遙侯爵

這篇文章主要介紹了java通過Callable和Future來接收線程池的執(zhí)行結(jié)果，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

在Java的線程執(zhí)行中，不管是直接繼承Thread的方式，還是實現(xiàn)Runnable接口的方式，都不會獲取到線程執(zhí)行的返回結(jié)果。這樣如果線程在執(zhí)行過程中出現(xiàn)了錯誤，那么主線程也不會感知到。即使打印了日志，也不能立即拋出異常。事后查看日志才能發(fā)現(xiàn)出現(xiàn)了bug。而且到那時發(fā)生問題的代碼點距離真正的問題點可能會相差很遠(yuǎn)。如果在線程池執(zhí)行的過程中出現(xiàn)了bug能及時地拋出異常，那么這將會是一個很好的實現(xiàn)。解決上述問題的辦法是使用Callable接口，其可以獲取到線程的返回結(jié)果，通過Future的get方法來承接。以下通過一個1000個線程實現(xiàn)累加的例子，來演示Callable和Future的使用：

package com.hys.test;
 
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicInteger;
 
import com.google.common.util.concurrent.ThreadFactoryBuilder;
 
public class Test {
 
  private static AtomicInteger num = new AtomicInteger();
 
  public static void main(String[] args) throws InterruptedException, ExecutionException {
    CountDownLatch latch = new CountDownLatch(1000);
    ThreadFactory namedThreadFactory = new ThreadFactoryBuilder().setNameFormat("increment-pool-%d").build();
    ExecutorService poolexecutor = new ThreadPoolExecutor(1000, 1000, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(1024), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy());
    Future<String> submit = null;
    for (int i = 0; i < 1000; i++) {
      if (submit != null && submit.get() != null) {
        latch.countDown();
        continue;
      }
      submit = poolexecutor.submit(() -> {
        try {
          //這里模擬一個耗時很長的操作
          num.getAndIncrement();
          //int a = 1 / 0;
          Thread.sleep(1);
          return null;
        } catch (Exception e) {
          return e.toString();
        } finally {
          latch.countDown();
        }
      });
    }
    poolexecutor.shutdown();
    //主線程等待所有分線程執(zhí)行完畢后再執(zhí)行
    latch.await();
    String errorMsg = submit.get();
    //如果子線程在執(zhí)行過程中有錯誤，則在此拋出該異常
    if (errorMsg != null) {
      throw new RuntimeException(errorMsg);
    }
    System.out.println(num);
  }
}

如果每個線程在執(zhí)行的過程中沒出現(xiàn)問題，則返回的結(jié)果為null。如果返回結(jié)果不為null，則代表該線程執(zhí)行的代碼有問題，此時將錯誤信息返回。放開上述第33行代碼的注釋，以此來模擬一個算術(shù)異常，再次執(zhí)行上述代碼，可以得到如下的結(jié)果：

Exception in thread "main" java.lang.RuntimeException: java.lang.ArithmeticException: / by zero
at com.hys.test.Test.main(Test.java:49)

由上可以看到，在主線程拋出了算術(shù)異常，可以被感知到。

但是需要注意的一點的是，如果線程的執(zhí)行結(jié)果互相依賴的話，也就是各線程都會調(diào)用Future的get方法的話，get方法不得不等待任務(wù)執(zhí)行完成，換言之，如果多個任務(wù)提交后，返回的多個Future逐一調(diào)用get方法時，將會依次阻塞，任務(wù)的執(zhí)行從并行變?yōu)榇小Ｈ绻虢鉀Q該問題，可以考慮使用Java 8中的CompletableFuture來實現(xiàn)。

以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: