Tanzu GemFire Distributed Types Java API Reference
Interface DBlockingQueue<E>
- Type Parameters:
E- the type of elements in this queue
- All Superinterfaces:
BlockingDeque<E>,BlockingQueue<E>,Collection<E>,Deque<E>,DType,Iterable<E>,Queue<E>
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, takeLastMethods inherited from interface java.util.concurrent.BlockingQueue
drainTo, drainTo, remainingCapacityMethods inherited from interface java.util.Collection
clear, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray, toArrayMethods inherited from interface java.util.Deque
addAll, descendingIterator, getFirst, getLast, peekFirst, peekLast, pollFirst, pollLast, pop, removeFirst, removeLast