Package de.hybris.platform.util
Class DefaultWorkerValueQueue<E>
java.lang.Object
de.hybris.platform.util.AbstractWorkerValueQueue<E>
de.hybris.platform.util.DefaultWorkerValueQueue<E>
- All Implemented Interfaces:
WorkerValueQueue<E>
-
Nested Class Summary
Nested classes/interfaces inherited from interface de.hybris.platform.util.WorkerValueQueue
WorkerValueQueue.ExecuteOnTaken<E>, WorkerValueQueue.ExecuteWhileWaiting<E> -
Field Summary
FieldsFields inherited from class de.hybris.platform.util.AbstractWorkerValueQueue
DEFAULT_WAIT_INTERVAL, DEFAULT_WAIT_INTERVAL_UNIT -
Constructor Summary
ConstructorsConstructorDescriptionDefaultWorkerValueQueue(int workerSize) DefaultWorkerValueQueue(int workerSize, int maxQueueSize) -
Method Summary
Modifier and TypeMethodDescriptionvoidclear()voidclearValueTaken(int workerNumber) booleanbooleanput(E value, WorkerValueQueue.ExecuteWhileWaiting<E> exec) voidstop()take(int workerNumber) voidwaitUntilEmpty(long time, TimeUnit timeUnit, WorkerValueQueue.ExecuteWhileWaiting<E> exec) Methods inherited from class de.hybris.platform.util.AbstractWorkerValueQueue
put, waitUntilEmpty, waitUntilEmpty
-
Field Details
-
DEFAULT_PUT_INTERVAL
public static final int DEFAULT_PUT_INTERVAL- See Also:
-
DEFAULT_PUT_INTERVAL_UNIT
-
-
Constructor Details
-
DefaultWorkerValueQueue
public DefaultWorkerValueQueue(int workerSize) -
DefaultWorkerValueQueue
public DefaultWorkerValueQueue(int workerSize, int maxQueueSize)
-
-
Method Details
-
stop
public void stop() -
executeOnTakenValues
-
take
-
clearValueTaken
public void clearValueTaken(int workerNumber) -
put
-
waitUntilEmpty
public void waitUntilEmpty(long time, TimeUnit timeUnit, WorkerValueQueue.ExecuteWhileWaiting<E> exec) -
clear
public void clear() -
isValueTakenOrQueueNotEmpty
public boolean isValueTakenOrQueueNotEmpty()
-