mingyifei commented on issue #15735: URL: https://github.com/apache/pulsar/issues/15735#issuecomment-1135566241
> Triplelongpriorityqueue is obviously not a thread safe queue. It is just an ordered queue based on bytebuf, which is used to store the index of long type and the delay time of long type. When you use it in the outer layer, you need to lock it to ensure its thread safety. ok. thanks. add() and pop() methods, i see PersistentDispatcherMultipleConsumers is the lock object. -- 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-unsubscr...@pulsar.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
