作者 | why技术
来源 | why技术(ID:hello_hi_why)
老规矩,先荒腔走板聊聊其他的。
上面这图是上周六,成都叁缺壹演唱会的现场。正在唱歌的这个男人叫做李志。去年他因为某些原因被 404 了。上周六他突然出现在成都,突然宣告着解除封印。
我知道这个消息是因为周六的晚上我正在看《乐队的夏天》。刚好是达达乐队正在唱《南方》,然后上面有一个弹幕:李志在成都复出啦!
于是我打开了微博,搜索:李志成都。果然看到了他的演出视频。视频里面唱的是《关于郑州我知道的不多》。
只是李志把歌词里面的郑州都改成了“成都”。一边是达达乐队唱着《南方》,一边是李志的《关于“成都”我知道的不多》。那一刻,我把这个消息分享给坐在旁边的女朋友,我张了张口,竟然突然一下有点说不出话来,只好把手机在她面前晃了一晃。
记得我之前在网抑云听李志的《梵高先生》的时候,无意间看了一下下面的评论,有一个评论的 ID 叫做放羊的壮年,他说:
今年五月十六日被确诊肺癌晚期,医生说还有三到五个月,然而到今天我还呼吸着这世界的空气,人生大起大落往往都是自己体会,这算是一种孤独吗?也许有一天我女儿也会爱上这首歌,那是不是比我更加孤独?怎么去想…
《梵高先生》的第一句歌词是:谁的父亲死了,请你告诉我如何悲伤。
他的留言日期是 2015 年 12 月 30 日。
我点进他的主页查看,他的头像是一个很可爱的小女孩,扎着两个小辫子。可能就是他的女儿吧,我看了他的听歌排行,点了最近一周,显示没有听歌排行数据。看了他的仅有的一条动态,里面有 4000 多个评论。
热评第一是这样说的:多少人和我一样看到梵高先生下的评论然后点进来点进最近一周听歌为空白心头一凉,不知道你现在还好不好,衷心祝愿你的女儿幸福。
他的评论里面充满了陌生人,言语之间充满了关怀和爱,有人和他像朋友一样留言聊天,有人说他换了播放器,有人说希望你是骗我们的...
评论看着看着就觉得很温暖。
隔了几天之后我也去留言了:我们生来就是孤独,但是人间温暖。
好了,说回文章。
上周不是写了《笑了,面试官问我知不知道异步编程的Future》这一篇文章聊 Future 嘛。
然后有读者就给我留言了:why哥,你都写到Future了,应该再写一下 CompletionService 的。上次面试就被面试官追问了。
我笑着说:哎呀,实在是没有时间写了。文章已经很长了,再把这个东西补充上去,更长了,没人看的。
读者说:没事,我就是一个小建议。
好的,接受建议。本文就来聊聊 CompletionService 这个东西。
在聊它之前,我们先回顾一下 Future 的用法。
我先问问你,当你往线程池里面提交了一组计算任务以后,你想要获得返回值。
你应该用 Executor 的什么提交方法?这个提交方法的什么重载类型?
什么?你答不上来?呸,你个渣男,上周白嫖完了就忘了?
上周的文章里面写了啊:
用 submit 的任务类型为 Callable 的或者任务类型为 Runable,还可以再传一个返回值的:
由于是一组计算任务,你想拿到返回值去搞事情。这个返回值就被封装在 Future 里面。
怎么获取呢?
调用 Future 的 get 方法,有不带超时时间的无限等待类型的 get,也有带超时时间、到点就放弃的渣男类型的 get:
来一起看个例子吧:
public class JDKThreadPoolExecutorTest {
public static void main(String[] args) throws Exception {
ExecutorService executorService = Executors.newCachedThreadPool();
ArrayList list = new ArrayList();
Future future_15 = executorService.submit(() -> {
TimeUnit.SECONDS.sleep(15);
System.out.println("执行时长为15s的执行完成。");
return 15;
});
list.add(future_15);
Future future_5 = executorService.submit(() -> {
TimeUnit.SECONDS.sleep(5);
System.out.println("执行时长为5s的执行完成。");
return 5;
});
list.add(future_5);
Future future_10 = executorService.submit(() -> {
TimeUnit.SECONDS.sleep(10);
System.out.println("执行时长为10s的执行完成。");
return 10;
});
list.add(future_10);
System.out.println("开始准备获取结果");
for (Future future : list) {
System.out.println("future.get() = " + future.get());
}
Thread.currentThread().join();
}
}
现在有三个任务,执行时间分别是 15s/10s/5s 。通过 JDK 线程池的 submit 方法提交了这三个 Callable 类型的任务。
你先眼神编译一下,心里输出一下,你想这个代码的输出结果是什么。
首先主线程把三个任务提交到线程池里面去,把对应返回的 Future 放到 List 里面存起来,然后执行“开始准备获取结果”的输出语句。
接着进入 for 循环,在循环里面执行 future.get() 操作,阻塞等待。
看看你心里想的输出结果是不是这样的:
从这个输出结果里面,我们可以看出问题了。很明显的木桶效应。
三个异步任务,耗时最长的最先执行,所以最先进入 list,因此当在循环中获取这个任务结果的时候 get 操作会一直阻塞,即使执行时间为 5s/10s 的任务已经执行完成。
好的,举个例子。想象一个场景:
假设你是一个海王,你拥有众多普通女性朋友。你同时邀约了三位女性朋友一起吃饭。分别给她们说:你先化妆吧,好了给我说一声,我开车来接你。
小红化妆要 2 小时。小花化妆要 1小时。小媛化妆要 30 分钟。
由于你最先给小红说的,你就一直在小红家门口等小红化妆完成。当小红化妆完成后,你接到车上,其他两位朋友早就准备好了,在家干巴巴的等着你来接她。
这不是一个合格的海王应该有的样子。
这就是 future 在这种场景下的局限性。
根据上面的场景编码可得(代码都是直接复制粘贴就可以用的,建议你拿出来跑一下):
public class JDKThreadPoolExecutorTest {
public static void main(String[] args) throws Exception {
ExecutorService executorService = Executors.newCachedThreadPool();
ArrayList list = new ArrayList();
System.out.println("约几个妹子一起吃个饭吧。");
Future future_15 = executorService.submit(() -> {
System.out.println("小红:好的,哥哥。我化妆要2个小时。等一下哦。");
TimeUnit.SECONDS.sleep(15);
System.out.println("小红:我2个小时准时化好了,哥哥来接我吧。");
return "小红化完了。";
});
list.add(future_15);
Future future_5 = executorService.submit(() -> {
System.out.println("小媛:好的,哥哥。我化妆要30分钟。等一下哦。");
TimeUnit.SECONDS.sleep(5);
System.out.println("小媛:我30分钟准时化好了,哥哥来接我吧。");
return "小媛化完了。";
});
list.add(future_5);
Future future_10 = executorService.submit(() -> {
System.out.println("小花:好的,哥哥。我化妆要1个小时。等一下哦。");
TimeUnit.SECONDS.sleep(10);
System.out.println("小花:我1个小时准时化好了,哥哥来接我吧。");
return "小花化完了。";
});
list.add(future_10);
TimeUnit.SECONDS.sleep(1);
System.out.println("都通知完,等着吧。");
for (Future future : list) {
System.out.println(future.get()+"我去接她。");
}
Thread.currentThread().join();
}
}
输出结果如下:
说好都是一样的普通朋友的,为什么你偏偏要一直等化妆时间最长的小红?为什么不谁动作快,就先接谁?
你看你这样操作,让小媛、小花怎么想?只能说:你是一个好人了。
什么?你个中央空调还问我“什么是海王”?
还是上面的场景,当我们引入了 CompletionService 后就显得不一样了。
先直接看用法:
ExecutorService executorService = Executors.newCachedThreadPool();
ExecutorCompletionService completionService = new ExecutorCompletionService(executorService);
用起来非常的方便,只需要用 ExecutorCompletionService 把线程池包起来。
然后提交任务的时候用 competitionService 的 submit 方法。代码如下:
public class ExecutorCompletionServiceTest {
public static void main(String[] args) throws Exception {
ExecutorService executorService = Executors.newCachedThreadPool();
ExecutorCompletionService completionService =
new ExecutorCompletionService(executorService);
System.out.println("约几个妹子一起吃个饭吧。");
completionService.submit(() -> {
System.out.println("小红:好的,哥哥。我化妆要2个小时。等一下哦。");
TimeUnit.SECONDS.sleep(15);
System.out.println("小红:我2个小时准时化好了,哥哥来接我吧。");
return "小红化完了。";
});
completionService.submit(() -> {
System.out.println("小媛:好的,哥哥。我化妆要30分钟。等一下哦。");
TimeUnit.SECONDS.sleep(5);
System.out.println("小媛:我30分钟准时化好了,哥哥来接我吧。");
return "小媛化完了。";
});
completionService.submit(() -> {
System.out.println("小花:好的,哥哥。我化妆要1个小时。等一下哦。");
TimeUnit.SECONDS.sleep(10);
System.out.println("小花:我1个小时准时化好了,哥哥来接我吧。");
return "小花化完了。";
});
TimeUnit.SECONDS.sleep(1);
System.out.println("都通知完,等着吧。");
//循环3次是因为上面提交了3个异步任务
for (int i = 0; i
关注
打赏


微信扫码登录