invokeAny和invokeAll的使用思路

这里我对invokeAny和invokeAll的使用思路想的很简单，就是根据方法的特点，去匹配相应的业务逻辑，比如说有个接口要调出航空的班次表，有北京航空的班次表，南京航空的班次表，天津航空的班次表，但是只要有一个航空公司返回了结果，其他两个就不用返回结果了，所以这里的业务要求是只需要返回响应最快的结果集，那么就可以使用invokeAny方法。

invokeAny方法demo

public static void main(String[] args) throws InterruptedException, ExecutionException {ExecutorService executorService = Executors.newFixedThreadPool(3);List<Callable<String>> tasks = new ArrayList<>();tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(1);return "北京航空的班次表";}});tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(2);return "南京航空的班次表";}});tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(3);return "天津航空的班次表";}});String result = executorService.invokeAny(tasks);System.out.println(result);executorService.shutdown();}

输出结果：

这里由于北京航空响应时间是最快的，所以优先返回了北京航空的班次表。

那么如果业务逻辑其实是需要获取3个接口的结果集，然后一起返回给前端的话，那么就不能只获取响应最快的结果集了，而是要等到结果全部返回才行

invokeAll方法demo

public static void main(String[] args) throws InterruptedException, ExecutionException {ExecutorService executorService = Executors.newFixedThreadPool(3);List<Callable<String>> tasks = new ArrayList<>();tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(1);return "北京航空的班次表";}});tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(2);return "南京航空的班次表";}});tasks.add(new Callable() {@Overridepublic Object call() throws Exception {TimeUnit.SECONDS.sleep(3);return "天津航空的班次表";}});List<Future<String>> result = executorService.invokeAll(tasks);for (Future future : result) {String aa = future.get().toString();System.out.println(aa);}executorService.shutdown();}

输出结果：

可以看出，使用invokeAll方法就可以得到多个线程的结果集了。

总结

这里没有深入分析invokeAny和invokeAll方法的各种细节，只是对invokeAny和invokeAll的使用思路做个简单的分享。

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！