Class ConcurrentApproximatePriorityQueue<T>


  • final class ConcurrentApproximatePriorityQueue<T>
    extends java.lang.Object
    Concurrent version of ApproximatePriorityQueue, which trades a bit more of ordering for better concurrency by maintaining multiple sub ApproximatePriorityQueues that are locked independently. The number of subs is computed dynamically based on hardware concurrency.
    • Constructor Detail

      • ConcurrentApproximatePriorityQueue

        ConcurrentApproximatePriorityQueue()
      • ConcurrentApproximatePriorityQueue

        ConcurrentApproximatePriorityQueue​(int concurrency)
    • Method Detail

      • getConcurrency

        private static final int getConcurrency()
      • add

        void add​(T entry,
                 long weight)
      • poll

        T poll​(java.util.function.Predicate<T> predicate)
      • contains

        boolean contains​(java.lang.Object o)
      • remove

        boolean remove​(java.lang.Object o)