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

2023-05-31 01:13

短信预约 -IT技能 免费直播动态提醒

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();          }        }      }    };  }}

免责声明：

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的，并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据，供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

java 多线程 future

阅读原文内容投诉