文章详情

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

请输入下面的图形验证码

提交验证

短信预约提醒成功

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

2023-05-31 01:13

关注

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

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 资料下载
  • 历年真题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     807人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     351人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     314人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     433人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     221人已做
    查看

相关文章

发现更多好内容
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯