首页 > 代码库 > 多线程篇七:通过Callable和Future获取线程池中单个务完成后的结果
多线程篇七:通过Callable和Future获取线程池中单个务完成后的结果
使用场景:如果需要拿到线程的结果,或者在线程完成后做其他操作,可以使用Callable 和 Futrue
1.定义一个线程池,向线程池中提交单个callable任务
ExecutorService threadPools=Executors.newSingleThreadExecutor(); Future<String> future=threadPools.submit(new Callable<String>() { @Override public String call() throws Exception { Thread.sleep(2000);//模拟任务处理2S return "hello"; } }); System.out.println("等待结果。。。。。"); try { System.out.println("获取到结果:"+future.get());//2S之后任务完成后获取到结果 } catch (Exception e) { e.printStackTrace(); }
2.CompletionService 用于提交一组callable任务,并获取每一个任务的结果
ExecutorService threadPools2=Executors.newFixedThreadPool(10); CompletionService<Integer> completetionService=new ExecutorCompletionService<Integer>(threadPools2); //提交10个任务 for(int i=1;i<=10;i++){ final int seq=i; completetionService.submit(new Callable<Integer>(){ @Override public Integer call() throws Exception { Thread.sleep(new Random().nextInt(5000)); return seq; } }); } for(int i=1;i<=10;i++){ Future<Integer> futures; try { futures = completetionService.take(); System.out.println("拿到任务结果:"+futures.get());//在任务完成后拿到结果,哪个任务先完成,则先拿到结果 } catch (Exception e) { e.printStackTrace(); } }
多线程篇七:通过Callable和Future获取线程池中单个务完成后的结果
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。