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/30 11:01:27 UTC

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

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


   > > > 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 q)]method.
   > > Iterate over the queue and find the first element that meets the conditions (or NULL)to calculate the time instead of the [peek()] method( think about the impact of concurrency).
   > 
   > Could you submit a pull request to fix the issue? I will review the code and help you merge.
   
   Ok, I will verify the scheme and give you feedback later. @RongtongJin 


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