just a question ,not a bug report
VERSION:4.7.0
DESC:
we found that ConsumeMessageConcurrentlyService#consumeExecutor use a nearly
infinite blocking queue,so the corePoolSize will always be this.defaultMQPushConsumer.getConsumeThreadMin(),is this.defaultMQPushConsumer.getConsumeThreadMax() a useless parameter? and we also find the method incCorePoolSize and decCorePoolSize which use to adjust corePoolSize , but it is commented out ,could you tell me why?
just a question ,not a bug report
VERSION:4.7.0
DESC:
we found that
ConsumeMessageConcurrentlyService#consumeExecutoruse a nearlyinfinite blocking queue,so the corePoolSize will always be
this.defaultMQPushConsumer.getConsumeThreadMin(),isthis.defaultMQPushConsumer.getConsumeThreadMax()a useless parameter? and we also find the methodincCorePoolSizeanddecCorePoolSizewhich use to adjust corePoolSize , but it is commented out ,could you tell me why?