为什么要注释掉ConsumeMessageConcurrentlyService的incCorePo

LinkedBlockingQueue没有指定size，消费线程池内线程不会自动增长。 并且注释掉了incCorePoolSize与decCorePoolSize函数，不会根据消息堆积情况来增减线程数，消费线程数会固定是ConsumeThreadMin，无法伸缩。想请教一下，这样做的目的是什么？

public class ConsumeMessageConcurrentlyService implements ConsumeMessageService {

 public ConsumeMessageConcurrentlyService(DefaultMQPushConsumerImpl defaultMQPushConsumerImpl,
    MessageListenerConcurrently messageListener) {
        //...
     this.consumeRequestQueue = new LinkedBlockingQueue<Runnable>();

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

      
@Override
public void incCorePoolSize() {
    // long corePoolSize = this.consumeExecutor.getCorePoolSize();
    // if (corePoolSize < this.defaultMQPushConsumer.getConsumeThreadMax())
    // {
    // this.consumeExecutor.setCorePoolSize(this.consumeExecutor.getCorePoolSize()
    // + 1);
    // }
    // log.info("incCorePoolSize Concurrently from {} to {}, ConsumerGroup:
    // {}",
    // corePoolSize,
    // this.consumeExecutor.getCorePoolSize(),
    // this.consumerGroup);
}

@Override
public void decCorePoolSize() {
    // long corePoolSize = this.consumeExecutor.getCorePoolSize();
    // if (corePoolSize > this.defaultMQPushConsumer.getConsumeThreadMin())
    // {
    // this.consumeExecutor.setCorePoolSize(this.consumeExecutor.getCorePoolSize()
    // - 1);
    // }
    // log.info("decCorePoolSize Concurrently from {} to {}, ConsumerGroup:
    // {}",
    // corePoolSize,
    // this.consumeExecutor.getCorePoolSize(),
    // this.consumerGroup);
}

}

原提问者GitHub用户crazy-pizza