Package de.hybris.platform.util

Interface WorkerValueQueue<E>

All Known Implementing Classes:

AbstractWorkerValueQueue, DefaultWorkerValueQueue, DeprecatedWorkerValueQueue

public interface WorkerValueQueue<E>

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	WorkerValueQueue.ExecuteOnTaken<E>
static interface	WorkerValueQueue.ExecuteWhileWaiting<E>

Method Summary

Modifier and Type	Method	Description
void	clear()
void	clearValueTaken(int workerNumber)
java.lang.Object	executeOnTakenValues(WorkerValueQueue.ExecuteOnTaken<E> exec)
boolean	isValueTakenOrQueueNotEmpty()
void	put(E value)
boolean	put(E value, WorkerValueQueue.ExecuteWhileWaiting<E> exec)
void	stop()
E	take(int workerNumber)
void	waitUntilEmpty()
void	waitUntilEmpty(long time, java.util.concurrent.TimeUnit timeUnit, WorkerValueQueue.ExecuteWhileWaiting<E> exec)
void	waitUntilEmpty(WorkerValueQueue.ExecuteWhileWaiting<E> exec)

Method Detail

executeOnTakenValues

java.lang.Object executeOnTakenValues(WorkerValueQueue.ExecuteOnTaken<E> exec)

take

E take(int workerNumber)

clearValueTaken

void clearValueTaken(int workerNumber)

put

void put(E value)

put

boolean put(E value,
            WorkerValueQueue.ExecuteWhileWaiting<E> exec)

waitUntilEmpty

void waitUntilEmpty()

waitUntilEmpty

void waitUntilEmpty(WorkerValueQueue.ExecuteWhileWaiting<E> exec)

waitUntilEmpty

void waitUntilEmpty(long time,
                    java.util.concurrent.TimeUnit timeUnit,
                    WorkerValueQueue.ExecuteWhileWaiting<E> exec)

clear

void clear()

isValueTakenOrQueueNotEmpty

boolean isValueTakenOrQueueNotEmpty()

stop

void stop()