Java中多线程对运行结果怎么利用future获取

Java中多线程对运行结果怎么利用future获取？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

Future接口是Java标准api的一部分，在java.util.concurrent包中。Future接口是Java线程Future模式的实现，可以来进行异步计算。

有了Future就可以进行三段式的编程了，1.启动多线程任务2.处理其他事3.收集多线程任务结果。从而实现了非阻塞的任务调用。在途中遇到一个问题，那就是虽然能异步获取结果，但是Future的结果需要通过isdone来判断是否有结果，或者使用get()函数来阻塞式获取执行结果。这样就不能实时跟踪其他线程的结果状态了，所以直接使用get还是要慎用，最好配合isdone来使用。

这里有一种更好的方式来实现对任意一个线程运行完成后的结果都能及时获取的办法：使用CompletionService，它内部添加了阻塞队列，从而获取future中的值，然后根据返回值做对应的处理。一般future使用和CompletionService使用的两个测试案例如下：

import java.util.ArrayList;import java.util.List;import java.util.Random;import java.util.concurrent.Callable;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;import java.util.concurrent.Future;public class AsyncThread {  public static void main(String[] args) {    AsyncThread t = new AsyncThread();    List<Future<String>> futureList = new ArrayList<Future<String>>();    t.generate(3, futureList);    t.doOtherThings();    t.getResult(futureList);  }    public void generate(int threadNum, List<Future<String>> fList) {    ExecutorService service = Executors.newFixedThreadPool(threadNum);    for (int i = 0; i < threadNum; i++) {      Future<String> f = service.submit(getJob(i));      fList.add(f);    }    service.shutdown();  }    public void doOtherThings() {    try {      for (int i = 0; i < 3; i++) {        System.out.println("do thing no:" + i);        Thread.sleep(1000 * (new Random().nextInt(10)));      }    } catch (InterruptedException e) {      e.printStackTrace();    }  }    public void getResult(List<Future<String>> fList) {    ExecutorService service = Executors.newSingleThreadExecutor();    service.execute(getCollectJob(fList));    service.shutdown();  }    public Callable<String> getJob(final int i) {    final int time = new Random().nextInt(10);    return new Callable<String>() {      @Override      public String call() throws Exception {        Thread.sleep(1000 * time);        return "thread-" + i;      }    };  }    public Runnable getCollectJob(final List<Future<String>> fList) {    return new Runnable() {      public void run() {        for (Future<String> future : fList) {          try {            while (true) {              if (future.isDone() && !future.isCancelled()) {                System.out.println("Future:" + future                    + ",Result:" + future.get());                break;              } else {                Thread.sleep(1000);              }            }          } catch (Exception e) {            e.printStackTrace();          }        }      }    };  }}