public class DefaultWorkerValueQueue<E> extends AbstractWorkerValueQueue<E>
WorkerValueQueue.ExecuteOnTaken<E>, WorkerValueQueue.ExecuteWhileWaiting<E>| Modifier and Type | Field and Description |
|---|---|
static int |
DEFAULT_PUT_INTERVAL |
static java.util.concurrent.TimeUnit |
DEFAULT_PUT_INTERVAL_UNIT |
DEFAULT_WAIT_INTERVAL, DEFAULT_WAIT_INTERVAL_UNIT| Constructor and Description |
|---|
DefaultWorkerValueQueue(int workerSize) |
DefaultWorkerValueQueue(int workerSize,
int maxQueueSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
clear() |
void |
clearValueTaken(int workerNumber) |
java.lang.Object |
executeOnTakenValues(WorkerValueQueue.ExecuteOnTaken<E> exec) |
boolean |
isValueTakenOrQueueNotEmpty() |
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<E> exec) |
put, waitUntilEmpty, waitUntilEmptypublic static final int DEFAULT_PUT_INTERVAL
public static final java.util.concurrent.TimeUnit DEFAULT_PUT_INTERVAL_UNIT
public DefaultWorkerValueQueue(int workerSize)
public DefaultWorkerValueQueue(int workerSize,
int maxQueueSize)
public void stop()
public java.lang.Object executeOnTakenValues(WorkerValueQueue.ExecuteOnTaken<E> exec)
public E take(int workerNumber)
public void clearValueTaken(int workerNumber)
public boolean put(E value, WorkerValueQueue.ExecuteWhileWaiting<E> exec)
public void waitUntilEmpty(long time,
java.util.concurrent.TimeUnit timeUnit,
WorkerValueQueue.ExecuteWhileWaiting<E> exec)
public void clear()
public boolean isValueTakenOrQueueNotEmpty()
Copyright © 2018 SAP SE. All Rights Reserved.