异步消费者模式

提供一个最长 flush time,以及一个队列最长长度,
如果到这个时间阈值,队列还没满,那么直接清空队列进行消费
如果还没到时间阈值,队列满了,就直接清空队列进行消费
需要考虑消费者过慢的问题,提供多个消费者,在多个线程中进行消费,避免 block
有很多实现方式,参考ElasticSearch 的 BulkProcessor