Uses of Interface
com.hazelcast.internal.util.concurrent.QueuedPipe

Packages that use QueuedPipe

Package	Description
com.hazelcast.internal.util.concurrent	Concurrent queues etc.

Uses of QueuedPipe in com.hazelcast.internal.util.concurrent

Classes in com.hazelcast.internal.util.concurrent that implement QueuedPipe

Modifier and Type	Class and Description
class	ManyToOneConcurrentArrayQueue<E> Many producers to single consumer concurrent queue backed by an array.
class	OneToOneConcurrentArrayQueue<E> Single producer to single consumer concurrent queue backed by an array.

Methods in com.hazelcast.internal.util.concurrent that return QueuedPipe

Modifier and Type	Method and Description
QueuedPipe<E>	ConcurrentConveyor.queue(int index)

Methods in com.hazelcast.internal.util.concurrent with parameters of type QueuedPipe

Modifier and Type	Method and Description
static <E1> ConcurrentConveyor<E1>	ConcurrentConveyor.concurrentConveyor(E1 submitterGoneItem, QueuedPipe<E1>... queues) Creates a new concurrent conveyor.
static <E1> ConcurrentConveyorSingleQueue<E1>	ConcurrentConveyorSingleQueue.concurrentConveyorSingleQueue(E1 submitterGoneItem, QueuedPipe<E1> queue) Creates a new concurrent conveyor with a single queue.