RocketMQ使用consumerThreadMin、consumerThreadMax的数量进行

当我使用消息时，增加consumerThreadMax的值是不起作用的。

希望当consumerThreadMax的值增加时，我的专家消费速度会更快

现在是即使我增加consumerThreadMax的值，消耗速度也保持稳定

4.3.0，我检查了最后一个版本，它仍然会发生。

我在类ConsumerMessageConcurrentlyService中找到了一些： 公共ConsumerMessageConcurrentlyService（DefaultMQPushConsumerImpl DefaultMQPushConsumerImpl， 消息侦听器并发消息侦听器）{ this.defaultMQPushConsumerImpl=defaultMQPush ConsumerImpl； this.messageListener=消息侦听器；

this.defaultMQPushConsumer = this.defaultMQPushConsumerImpl.getDefaultMQPushConsumer();
this.consumerGroup = this.defaultMQPushConsumer.getConsumerGroup();
this.consumeRequestQueue = new LinkedBlockingQueue<Runnable>();

this.consumeExecutor = new ThreadPoolExecutor(
    this.defaultMQPushConsumer.getConsumeThreadMin(),
    this.defaultMQPushConsumer.getConsumeThreadMax(),
    1000 * 60,
    TimeUnit.MILLISECONDS,
    this.consumeRequestQueue,
    new ThreadFactoryImpl("ConsumeMessageThread_"));

this.scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl("ConsumeMessageScheduledThread_"));
this.cleanExpireMsgExecutors = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl("CleanExpireMsgScheduledThread_"));

}

该构造函数将无界队列（new LinkedBlockingQueue（））作为workQueue，它有一个风险，即当新任务到来时，如果数量等于consumeThreadMin，它将被推送到无界队列，consume线程数量将永远不会增加。因此consumerThreadMax值永远不会起作用因此consumerRequestQueue应该被分配为一个有界队列作为workQueue，比如this.consumerRequestQueue=new LinkedBlockingQueue（128）；

原提问者GitHub用户zhangdp-taozi