org.agrona.concurrent

Interface QueuedPipe<E>

Type Parameters:

E - type of the elements stored in the Queue.

All Superinterfaces:

java.util.Collection<E>, java.lang.Iterable<E>, Pipe<E>, java.util.Queue<E>

All Known Implementing Classes:

AbstractConcurrentArrayQueue, ManyToManyConcurrentArrayQueue, ManyToOneConcurrentArrayQueue, OneToOneConcurrentArrayQueue

public interface QueuedPipe<E>
extends java.util.Queue<E>, Pipe<E>

Composed interface for concurrent Queue and Pipe.

Method Summary

Methods inherited from interface java.util.Queue

add, element, offer, peek, poll, remove

Methods inherited from interface java.util.Collection

addAll, clear, contains, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, remove, removeAll, removeIf, retainAll, size, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Methods inherited from interface org.agrona.concurrent.Pipe

addedCount, capacity, drain, drain, drainTo, remainingCapacity, removedCount, size