Class ManagedConcurrentLinkedQueue<T>

  • Type Parameters:
    T - the type of values to store
    All Implemented Interfaces:

    public class ManagedConcurrentLinkedQueue<T>
    extends Object
    implements Iterable<T>
    A queue that stores values wrapped in a Reference, the type of which is determined by the provided ReferenceBundle. References stored in this queue will be removed when reference processing occurs.

    This queue is backed by a ConcurrentLinkedQueue and is thread safe. The iterator will only return non-null values (reachable) and is based on the "weakly consistent" iterator of the underlying ConcurrentLinkedQueue.

    • Constructor Detail

      • ManagedConcurrentLinkedQueue

        public ManagedConcurrentLinkedQueue​(ReferenceBundle bundle)
        Creates an empty ManagedConcurrentLinkedQueue that will use the provided ReferenceBundle to store values as the given Reference type.
        bundle - used to create the appropriate Reference type for the values stored
    • Method Detail

      • add

        public void add​(T value)
        Adds the specified value to the queue.
        value - the value to add
      • isEmpty

        public boolean isEmpty()
        Returns true if this queue contains no elements.

        This method does not check the elements to verify they contain non-null reference values.

      • toArray

        public T[] toArray​(T[] tArray)
        Returns an array containing all values from this queue in the sequence they were added.
        tArray - the array to populate if big enough, else a new array with the same runtime type
        an array containing all non-null values in this queue
      • values

        public List<T> values()
        Returns a list containing all values from this queue in the sequence they were added.
      • iterator

        public Iterator<T> iterator()
        Returns an iterator over all non-null values in this queue. The values should be returned in the order they were added.
        Specified by:
        iterator in interface Iterable<T>