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: [email protected]
