[GitHub] tastypinenut opened a new issue #281: consumeThreadMax不会生效

[GitBox]

tastypinenut opened a new issue #281: consumeThreadMax不会生效
URL: https://github.com/apache/rocketmq/issues/281
 
 
   > 当线程数>=corePoolSize，且任务队列已满时。线程池会创建新线程来处理任务
   
   
但LinkedBlockingQueue的size为Integer.MAX_VALUE，正常业务不可能达到这个值，所以似乎consumeThreadMax永远不会生效
   
   `
           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 is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org


With regards,
Apache Git Services