public class ValueActorQueue<T> extends java.lang.Object implements ActorQueueApi<T>
| Constructor and Description |
|---|
ValueActorQueue(int capacity,
ActorProcessor<? super T>... processors) |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
int |
getAvailable() |
int |
getSize() |
java.lang.String |
getWorkerState() |
boolean |
isEmpty() |
void |
offer(T value) |
boolean |
offer(T value,
boolean isWait) |
java.lang.String |
toString() |
void |
wake() |
public ValueActorQueue(int capacity,
ActorProcessor<? super T>... processors)
public int getAvailable()
getAvailable in interface ActorQueueApi<T>public boolean isEmpty()
isEmpty in interface ActorQueueApi<T>public int getSize()
getSize in interface ActorQueueApi<T>public final void offer(T value)
offer in interface ActorQueueApi<T>public final boolean offer(T value, boolean isWait)
offer in interface ActorQueueApi<T>public java.lang.String getWorkerState()
public void wake()
wake in interface ActorQueueApi<T>public void close()
public java.lang.String toString()
toString in class java.lang.Object