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 2020/12/27 15:37:50 UTC

[GitHub] [rocketmq] xxd763795151 commented on issue #2516: [4.7.1]the value of sendThreadPoolQueueHeadWaitTimeMills is 0 most of the time

xxd763795151 commented on issue #2516:
URL: https://github.com/apache/rocketmq/issues/2516#issuecomment-751481835


   > Maybe we could replace to a separate thread pool when we use thenAcceptAsync @xxd763795151
   
   Of course, this may be the quickest way, if its scope of influence is small enough.
   Think it about another way:  modify the [ public long headSlowTimeMills(BlockingQueue<Runnable> q)]method.
   Iterate over the queue and find the first element that meets the conditions (or NULL)to cacluete the time instead of the [peek()] method( think about the impact of concurrency).


----------------------------------------------------------------
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.

For queries about this service, please contact Infrastructure at:
users@infra.apache.org