java 線程public void run()中值如何返回

  • 2019 年 12 月 7 日
  • 筆記

Executor 接口 執行已提交的 Runnable 任務的對象。此接口提供一種將任務提交與每個任務將如何運行的機制（包括線程使用的細節、調度等）分離開來的方法。通常使用 Executor 而不是顯式地創建線程。例如，可能會使用以下方法，而不是為一組任務中的每個任務調用 new Thread(new(RunnableTask())).start()：  Executor executor = anExecutor;  executor.execute(new RunnableTask1()); Future<V>接口表示異步計算的結果，提供了檢查計算是否完成的方法，以等待計算的完成，並獲取計算的結果。 沒有構造器 boolean cancel(boolean mayInterruptIfRunning)試圖取消對此任務的執行 V get()如有必要，等待計算完成，然後獲取其結果 V get(long timeout, TimeUnit unit) boolean isCancelled()如果在任務正常完成前將其取消，則返回 true boolean isDone()如果任務已完成，則返回 true Executors類中都是靜態方法 Thread類，程序中的執行線程。

方法一：Java5新增了Callable接口獲得線程的返回值

import java.util.concurrent.Callable;  import java.util.concurrent.ExecutionException;  import java.util.concurrent.ExecutorService;  import java.util.concurrent.Executors;  import java.util.concurrent.Future;    public class GetReturnValueFromCallable {        private static final int SLEEP_MILLS = 3000;        private static final int SECOND_MILLS = 1000;        private static int sleepSeconds = SLEEP_MILLS / SECOND_MILLS;        ExecutorService executorService = Executors.newCachedThreadPool();        /**       * 在創建多線程程序的時候，我們常實現Runnable接口，Runnable沒有返回值，要想獲得返回值，Java5提供了一個新的接口Callable       */      public static void main(String[] args) {            new GetReturnValueFromCallable().testCallable();      }        private void testCallable() {            /**           * Callable需要實現的是call()方法，而不是run()方法，返回值的類型有Callable的類型參數指定，           * Callable只能由ExecutorService.submit() 執行，正常結束後將返回一個future對象           */          Future<String> future = executorService.submit(new Callable<String>() {                public String call() throws Exception {                  Thread.sleep(SLEEP_MILLS);                  return "I from callable";              }          });            while (true) {              /**               * 獲得future對象之前可以使用isDone()方法檢測future是否完成，完成後可以調用get()方法獲得future的值，               * 如果直接調用get()方法，get()方法將阻塞值線程結束               */              if (future.isDone()) {                  try {                      System.out.println(future.get());                      break;                  } catch (InterruptedException e) {                      // ignored                  } catch (ExecutionException e) {                      // ignored                  }              }              else {                  try {                      System.out.println("after " + sleepSeconds-- + " seconds, we will get future");                      Thread.sleep(SECOND_MILLS);                  } catch (InterruptedException e) {                      // ignored                  }              }          }      }  }

輸出結果： after 3 seconds, we will get future  after 2 seconds, we will get future  after 1 seconds, we will get future  I from callable 方法二： 在 run 方法方法中觸發一些事件（如啟動一個 Timer），再在讓事件監聽器函數返回那些被操作大的值

VirMach 便宜 VPS

QNews

QNews