BatchConsumeBlockingQueueTrigger doesn't consume data with expected bulk size

[liudunxu]

version: lastest

JVM version (java -version):

1.8

Description of the problem including expected versus actual behavior: I constructed BatchConsumeBlockingQueueTrigger with the following arguments: batchSize:1000 lingerMs:5000 The enqueue qps is 200/s and it spent 50ms to consume the bulk data despite the number of the bulk data. expected behavior the consumer function invoke every 5 seconds with about 1000 data. actual behavior the consumer function invoked more than 5 times in 1 seconds and the number of bulk data less than 200.

[PhantomThief]

@liudunxu Maybe add a maxWaitForBulk option for batch optimize.