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