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