com.hazelcast.internal.util.concurrent

Class ConcurrentConveyorSingleQueue<E>

java.lang.Object

com.hazelcast.internal.util.concurrent.ConcurrentConveyor<E>

com.hazelcast.internal.util.concurrent.ConcurrentConveyorSingleQueue<E>

public final class ConcurrentConveyorSingleQueue<E>
extends ConcurrentConveyor<E>

Specialization of ConcurrentConveyor to a single queue.

Field Summary

Fields inherited from class com.hazelcast.internal.util.concurrent.ConcurrentConveyor

SUBMIT_IDLER, SUBMIT_MAX_PARK_MICROS, SUBMIT_SPIN_COUNT, SUBMIT_YIELD_COUNT

Method Summary

Modifier and Type	Method and Description
static <E1> ConcurrentConveyorSingleQueue<E1>	concurrentConveyorSingleQueue(E1 submitterGoneItem, QueuedPipe<E1> queue) Creates a new concurrent conveyor with a single queue.
boolean	offer(E item) Offers an item to the queue.
void	submit(E item) Submits an item to the queue.

Methods inherited from class com.hazelcast.internal.util.concurrent.ConcurrentConveyor

awaitDrainerGone, backpressureOff, backpressureOn, checkDrainerGone, concurrentConveyor, drain, drainerArrived, drainerDone, drainerFailed, drainTo, drainTo, drainTo, drainTo, isDrainerGone, liveQueueCount, offer, offer, queue, queueCount, removeQueue, submit, submitterGoneItem

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

concurrentConveyorSingleQueue

public static <E1> ConcurrentConveyorSingleQueue<E1> concurrentConveyorSingleQueue(E1 submitterGoneItem,
                                                                                   QueuedPipe<E1> queue)

Creates a new concurrent conveyor with a single queue.

Parameters:

submitterGoneItem - the object that a submitter thread can use to signal it's done submitting

queue - the concurrent queue the conveyor will manage

offer

public boolean offer(E item)
              throws ConcurrentConveyorException

Offers an item to the queue.

Returns:

whether the item was accepted by the queue

Throws:

ConcurrentConveyorException - if the draining thread has already left

submit

public void submit(E item)
            throws ConcurrentConveyorException

Submits an item to the queue.

Throws:

ConcurrentConveyorException - if the current thread is interrupted or the draining thread has already left