You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/10/12 07:37:00 UTC
[GitHub] [rocketmq] 1zhangyan opened a new issue, #5290: consumeThreadMax can not work in most cases
1zhangyan opened a new issue, #5290:
URL: https://github.com/apache/rocketmq/issues/5290
Even though I set the param consumeThreadMax of DefaultMQPushConsumer, I find it do not work.
--
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: dev-unsubscribe@rocketmq.apache.org.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] ni-ze commented on issue #5290: consumeThreadMax can not work in most cases
Posted by GitBox <gi...@apache.org>.
ni-ze commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1278365645
It does look like that, umm, what is your suggest?
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] consumeThreadMax can not work in most cases [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1767381436
This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 1zhangyan commented on issue #5290: consumeThreadMax can not work in most cases
Posted by GitBox <gi...@apache.org>.
1zhangyan commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1275752731
And when I set it sleep 10s , the concurrency num is only 2. consumeThreadMax
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 1zhangyan commented on issue #5290: consumeThreadMax can not work in most cases
Posted by GitBox <gi...@apache.org>.
1zhangyan commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1275739728
Here is an example.
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] consumeThreadMax can not work in most cases [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #5290: consumeThreadMax can not work in most cases
URL: https://github.com/apache/rocketmq/issues/5290
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [rocketmq] 1zhangyan commented on issue #5290: consumeThreadMax can not work in most cases
Posted by GitBox <gi...@apache.org>.
1zhangyan commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1280197123
May be we can set a smaller value such as 200 for LinkedBlockingQueue which is set for target ThreadPoolExecutor.Also set the RejectedExecutionHandler as CallerRunsPolicy.
In this way, when the BlockingQueue size gets to 200, ThreadPoolExecutor will start new threads to help.
If the threads quantity becomes consumeThreadMax, and the blocking queue is full, the new message will be processed by the thread who submits tasks. Which makes it seem to be blocked.
--
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: dev-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
Re: [I] consumeThreadMax can not work in most cases [rocketmq]
Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #5290:
URL: https://github.com/apache/rocketmq/issues/5290#issuecomment-1773950802
This issue was closed because it has been inactive for 3 days since being marked as stale.
--
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: commits-unsubscribe@rocketmq.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org