提供一个最长 flush time,以及一个队列最长长度,
如果到这个时间阈值,队列还没满,那么直接清空队列进行消费
如果还没到时间阈值,队列满了,就直接清空队列进行消费
需要考虑消费者过慢的问题,提供多个消费者,在多个线程中进行消费,避免 block
有很多实现方式,参考ElasticSearch 的 BulkProcessor
异步消费者模式
©著作权归作者所有,转载或内容合作请联系作者
- 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
- 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
- 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
推荐阅读更多精彩内容
- 整体流程: 数据写入buffer缓冲和translog日志文件中。当你写一条数据document的时候,一方面写入...
- 本系列读书笔记是小荻老师发起的《刻意练习》读书活动的产出。以后一个月的时间里,都会以「阅读」+「思考」+「想法」的...