rx.internal.util

Class SynchronizedQueue<T>

  • Type Parameters:
    T -
    All Implemented Interfaces:
    Iterable<T>, Collection<T>, Queue<T> 

    public class SynchronizedQueue<T>
extends Object
implements Queue<T>
    Intended for use when the `sun.misc.Unsafe` implementations can't be used.

    • Constructor Detail

      • SynchronizedQueue

        public SynchronizedQueue()

      • SynchronizedQueue

        public SynchronizedQueue(int size)

    • Method Detail

      • isEmpty

        public boolean isEmpty()

      • contains

        public boolean contains(Object o)

      • size

        public int size()

      • add

        public boolean add(T e)

      • remove

        public boolean remove(Object o)

      • containsAll

        public boolean containsAll(Collection<?> c)

      • addAll

        public boolean addAll(Collection<? extends T> c)

      • removeAll

        public boolean removeAll(Collection<?> c)

      • retainAll

        public boolean retainAll(Collection<?> c)

      • clear

        public void clear()

      • toString

        public String toString()

      • equals

        public boolean equals(Object o)

      • hashCode

        public int hashCode()

      • peek

        public T peek()

      • element

        public T element()

      • poll

        public T poll()

      • remove

        public T remove()

      • offer

        public boolean offer(T e)

      • clone

        public Object clone()

      • toArray

        public Object[] toArray()

      • toArray

        public <R> R[] toArray(R[] a)