Package dev.gemfire.dtype

Interface DBlockingQueue<E>

  • Type Parameters:
    E - the type of elements in this queue
    All Superinterfaces:
    java.util.concurrent.BlockingDeque<E>, java.util.concurrent.BlockingQueue<E>, java.util.Collection<E>, java.util.Deque<E>, DType, java.lang.Iterable<E>, java.util.Queue<E>
    public interface DBlockingQueue<E>
extends java.util.concurrent.BlockingDeque<E>, DType
    An implementation of a BlockingDeque that is distributed and highly available. Most operations are forwarded to the backend cluster where the actual data is maintained. Objects added to a queue need to be serializable either as Java Serializable or one of GemFire's serializable types such as DataSerializable.

    Note that iteration methods will serialize the whole structure to the client and perform the iteration locally. Iterators do not support remove() and will throw an UnsupportedOperationException.

    Note that methods that are interruptible can only be interrupted locally. There is no interrupt 'signal' that is passed to the server performing the actual operation.

    • Method Summary

      • Methods inherited from interface java.util.concurrent.BlockingDeque

        add, addFirst, addLast, contains, element, iterator, offer, offer, offerFirst, offerFirst, offerLast, offerLast, peek, poll, poll, pollFirst, pollLast, push, put, putFirst, putLast, remove, remove, removeFirstOccurrence, removeLastOccurrence, size, take, takeFirst, takeLast

      • Methods inherited from interface java.util.concurrent.BlockingQueue

        drainTo, drainTo, remainingCapacity

      • Methods inherited from interface java.util.Collection

        clear, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArray

      • Methods inherited from interface java.util.Deque

        addAll, descendingIterator, getFirst, getLast, peekFirst, peekLast, pollFirst, pollLast, pop, removeFirst, removeLast

      • Methods inherited from interface java.lang.Iterable

        forEach