這篇文章主要介紹“Java如何使用ExecutorService停止線程服務(wù)的方法”，在日常操作中，相信很多人在Java如何使用ExecutorService停止線程服務(wù)的方法問題上存在疑惑，小編查閱了各式資料，整理出簡單好用的操作方法，希望對(duì)大家解答”Java如何使用ExecutorService停止線程服務(wù)的方法”的疑惑有所幫助！接下來，請(qǐng)跟著小編一起來學(xué)習(xí)吧！

創(chuàng)新互聯(lián)建站專注于宜良網(wǎng)站建設(shè)服務(wù)及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗(yàn)。 熱誠為您提供宜良營銷型網(wǎng)站建設(shè)，宜良網(wǎng)站制作、宜良網(wǎng)頁設(shè)計(jì)、宜良網(wǎng)站官網(wǎng)定制、重慶小程序開發(fā)服務(wù)，打造宜良網(wǎng)絡(luò)公司原創(chuàng)品牌,更為您提供宜良網(wǎng)站排名全網(wǎng)營銷落地服務(wù)。

Java可以用來干什么

Java主要應(yīng)用于：1. web開發(fā)；2. Android開發(fā)；3. 客戶端開發(fā)；4. 網(wǎng)頁開發(fā)；5. 企業(yè)級(jí)應(yīng)用開發(fā)；6. Java大數(shù)據(jù)開發(fā)；7.游戲開發(fā)等。

使用ExecutorService來停止線程服務(wù)

之前的文章中我們提到了ExecutorService可以使用shutdown和shutdownNow來關(guān)閉。

這兩種關(guān)閉的區(qū)別在于各自的安全性和響應(yīng)性。shutdownNow強(qiáng)行關(guān)閉速度更快，但是風(fēng)險(xiǎn)也更大，因?yàn)槿蝿?wù)可能正在執(zhí)行的過程中被結(jié)束了。而shutdown正常關(guān)閉雖然速度比較慢，但是卻更安全，因?yàn)樗恢钡鹊疥?duì)列中的所有任務(wù)都執(zhí)行完畢之后才關(guān)閉。

使用shutdown

我們先看一個(gè)使用shutdown的例子:

  public void useShutdown() throws InterruptedException {
    ExecutorService executor = Executors.newFixedThreadPool(10);

    Runnable runnableTask = () -> {
      try {
        TimeUnit.MILLISECONDS.sleep(300);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    };

    executor.submit(runnableTask);
    executor.shutdown();
    executor.awaitTermination(800, TimeUnit.MILLISECONDS);
  }

awaitTermination將會(huì)阻塞直到所有正在執(zhí)行的任務(wù)完成，或者達(dá)到指定的timeout時(shí)間。

使用shutdownNow

當(dāng)通過shutdownNow來強(qiáng)行關(guān)閉ExecutorService是， 它會(huì)嘗試取消正在執(zhí)行的任務(wù)，并返回所有已經(jīng)提交但是還沒有開始的任務(wù)。從而可以將這些任務(wù)保存起來，以便以后進(jìn)行處理。

但是這樣我們只知道了還沒有開始執(zhí)行的任務(wù)，對(duì)于那些已經(jīng)開始執(zhí)行但是沒有執(zhí)行完畢卻被取消的任務(wù)我們無法獲取。

我們看下如何獲得開始執(zhí)行但是還沒有執(zhí)行完畢的任務(wù)：

public class TrackingExecutor extends AbstractExecutorService {
  private final ExecutorService executorService;
  private final Set<Runnable> taskCancelledAtShutdown= Collections.synchronizedSet(new HashSet<Runnable>());

  public TrackingExecutor(ExecutorService executorService){
     this.executorService=executorService;
  }
  @Override
  public void shutdown() {
    executorService.shutdown();
  }

  @Override
  public List<Runnable> shutdownNow() {
    return executorService.shutdownNow();
  }

  @Override
  public boolean isShutdown() {
    return executorService.isShutdown();
  }

  @Override
  public boolean isTerminated() {
    return executorService.isTerminated();
  }

  @Override
  public boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException {
    return executorService.awaitTermination(timeout,unit);
  }

  @Override
  public void execute(Runnable command) {
    executorService.execute(() -> {
      try {
        command.run();
      }finally {
        if(isShutdown() && Thread.currentThread().isInterrupted()){
          taskCancelledAtShutdown.add(command);
        }
      }
    });
  }

  public List<Runnable> getCancelledTask(){
    if(! executorService.isTerminated()){
      throw new IllegalStateException("executorService is not terminated");
    }
    return new ArrayList<>(taskCancelledAtShutdown);
  }
}

上面的例子中我們構(gòu)建了一個(gè)新的ExecutorService，他傳入一個(gè)ExecutorService，并對(duì)其進(jìn)行封裝。

我們重寫了execute方法，在執(zhí)行完畢判斷該任務(wù)是否被中斷，如果被中斷則將其添加到CancelledTask列表中。

并提供一個(gè)getCancelledTask方法來返回未執(zhí)行完畢的任務(wù)。

我們看下怎么使用：

  public void useShutdownNow() throws InterruptedException {
    TrackingExecutor trackingExecutor=new TrackingExecutor(Executors.newCachedThreadPool());

    Runnable runnableTask = () -> {
      try {
        TimeUnit.MILLISECONDS.sleep(300);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    };

    trackingExecutor.submit(runnableTask);
    List<Runnable> notrunList=trackingExecutor.shutdownNow();
    if(trackingExecutor.awaitTermination(800, TimeUnit.SECONDS)){
      List<Runnable> runButCancelledList= trackingExecutor.getCancelledTask();
    }
  }

trackingExecutor.shutdownNow()返回的是未執(zhí)行的任務(wù)。而trackingExecutor.getCancelledTask()返回的是被取消的任務(wù)。

上面的任務(wù)其實(shí)還有一個(gè)缺點(diǎn)，因?yàn)槲覀冊(cè)诖鎯?chǔ)被取消的任務(wù)列表的額時(shí)候taskCancelledAtShutdown.add(command)，因?yàn)橹暗呐袛嗖皇窃硬僮?，則可能會(huì)產(chǎn)生誤報(bào)。

到此，關(guān)于“Java如何使用ExecutorService停止線程服務(wù)的方法”的學(xué)習(xí)就結(jié)束了，希望能夠解決大家的疑惑。理論與實(shí)踐的搭配能更好的幫助大家學(xué)習(xí)，快去試試吧！若想繼續(xù)學(xué)習(xí)更多相關(guān)知識(shí)，請(qǐng)繼續(xù)關(guān)注創(chuàng)新互聯(lián)網(wǎng)站，小編會(huì)繼續(xù)努力為大家?guī)砀鄬?shí)用的文章！

網(wǎng)站題目：Java如何使用ExecutorService停止線程服務(wù)的方法
網(wǎng)頁路徑：http://aaarwkj.com/article38/ihhesp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供定制網(wǎng)站、商城網(wǎng)站、網(wǎng)頁設(shè)計(jì)公司、微信公眾號(hào)、云服務(wù)器、用戶體驗(yàn)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來源： 創(chuàng)新互聯(lián)