liuxuzxx commented on issue #2709:
URL: https://github.com/apache/rocketmq/issues/2709#issuecomment-1586687137
> config sendThreadPoolQueueCapacity, the default value is 10000 the message
show your config is 4
>
> ```
> rt.returnResponse(RemotingSysResponseCode.SYSTEM_BUSY,
String.format("[PCBUSY_CLEAN_QUEUE]broker busy, start flow control for a while,
period in queue: %sms, size of queue: %d", System.currentTimeMillis() -
rt.getCreateTimestamp(),
this.brokerController.getSendThreadPoolQueue().size()));
> ```
No ,the this.brokerController.getSendThreadPoolQueue().size() return the
sendThreadPoolQueue actually size ,not the config length!
this.brokerController.getSendThreadPoolQueue().size()的大小是sendThreadPoolQueue队列元素的个数，不是他的size不是capacity！
所以这个4只是说当前这个sendThreadPoolQueue队列当中含有4个元素，并不是说他的capacity(容量)是4
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
