超级开心给Apache RocketMQ提了个PR,采纳了
因公司需要,在rocketmq的官方文档上学下rocketmq,我在看官方提供的异步发送demo的时候有了个小疑问,demo如下
rocketmq异步发送demo
关于CountDownLauch的原理可以看看我之前的文章CountDownLauch解析,其实就是一个带阻塞功能的计数器。这里Apache RocketMQ又提供了一个coutdownlatch2,我看了代码,大致是为了设置一个等待时间又封装了下。
那么看到这里的demo,就有浓浓的疑问了,这里结合coutdownlatch和for循环,我猜测他的意思是基于这样一个场景的需要
我们想发100个消息,然后不管成功或者失败一定要发到mq上,但是由于这里是异步消息。因此我们直接for循环执行的话,仅仅是组装消息,遍历结束,但是消息打不打的到mq上还是未知的,后面又有个shutdownI()方法,如果不阻塞的话,很可能我们for里消息还没执行完呢,咱们实例直接没了。因此我觉得这里引用countdownlatch来阻塞主线程,直到全部消息打到mq后(不管成功或者失败,只要到发了就行),我们要立即释放主线程。
1.这里弄了计数器却没有减操作是什么个意思?
2.这里用计数器阻塞了主线程5秒但是跟消息发没发完没直接联系啊,我搞10W消息,难道你就估他大概一分钟执行完设置60秒?如果只想起睡眠作用那为啥不用 TimeUnit.SECONDS.sleep(5);代替呢?
先实践下果然达不到预期,我就先去提了个issues
本身作为工作还不到一年的毕业生对提pr这事有点不好意思,感觉人家大佬写的代码让我小兵子质疑不太好。就把这事忘了好几天,今天竟然又收到了Apahe让提pr的邮件我才想起来,然后down了代码提了一个pr给Apache。
他们效率极高,提了pr当晚就给修复了,很**感谢Apache RocketMQ团队的大佬们,让我感觉技术圈真的很open!
**