Package de.hybris.platform.util

Class DeprecatedWorkerValueQueue<E>

java.lang.Object

de.hybris.platform.util.AbstractWorkerValueQueue<E>

de.hybris.platform.util.DeprecatedWorkerValueQueue<E>

All Implemented Interfaces:

WorkerValueQueue<E>

public class DeprecatedWorkerValueQueue<E>
extends AbstractWorkerValueQueue<E>

This class represents the WorkerValueQueue implementation before 4.2.2 and is here only for performance testing.

Don't use it elsewhere!

Nested Class Summary

Nested classes/interfaces inherited from interface de.hybris.platform.util.WorkerValueQueue

WorkerValueQueue.ExecuteOnTaken<E>, WorkerValueQueue.ExecuteWhileWaiting<E>

Field Summary

Fields

Modifier and Type	Field	Description
static int	TIME_WAIT_PUT
static java.util.concurrent.TimeUnit	TIME_WAIT_PUT_UNIT

Fields inherited from class de.hybris.platform.util.AbstractWorkerValueQueue

DEFAULT_WAIT_INTERVAL, DEFAULT_WAIT_INTERVAL_UNIT

Constructor Summary

Constructors

Constructor	Description
DeprecatedWorkerValueQueue(int maxSize)

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(long time, java.util.concurrent.TimeUnit timeUnit, WorkerValueQueue.ExecuteWhileWaiting exec)

Methods inherited from class de.hybris.platform.util.AbstractWorkerValueQueue

waitUntilEmpty, waitUntilEmpty

Methods inherited from class java.lang.Object

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

Field Detail

TIME_WAIT_PUT

public static final int TIME_WAIT_PUT

See Also:

Constant Field Values

TIME_WAIT_PUT_UNIT

public static final java.util.concurrent.TimeUnit TIME_WAIT_PUT_UNIT

Constructor Detail

DeprecatedWorkerValueQueue

public DeprecatedWorkerValueQueue(int maxSize)

Method Detail

executeOnTakenValues

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

stop

public void stop()

take

public E take(int workerNumber)

clearValueTaken

public void clearValueTaken(int workerNumber)

put

public void put(E value)

Specified by:

put in interface WorkerValueQueue<E>

Overrides:

put in class AbstractWorkerValueQueue<E>

put

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

waitUntilEmpty

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

clear

public void clear()

isValueTakenOrQueueNotEmpty

public boolean isValueTakenOrQueueNotEmpty()