RongtongJin commented on issue #2516: URL: https://github.com/apache/rocketmq/issues/2516#issuecomment-751657399
> > 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. ---------------------------------------------------------------- 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: [email protected]
