com.caucho.env.actor
Class MultiworkerActorQueue<T>

java.lang.Object
  extended by com.caucho.env.actor.MultiworkerActorQueue<T>
All Implemented Interfaces:
ActorQueueApi<T>

public class MultiworkerActorQueue<T>
extends java.lang.Object
implements ActorQueueApi<T>

Interface for the transaction log.


Constructor Summary
MultiworkerActorQueue(int capacity, int multiworkerOffset, ActorProcessor<? super T>... processors)
           
 
Method Summary
 void close()
           
 int getAvailable()
           
 int getSize()
           
 boolean isEmpty()
           
 void offer(T value)
           
 boolean offer(T value, boolean isWait)
           
 java.lang.String toString()
           
 void wake()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

MultiworkerActorQueue

public MultiworkerActorQueue(int capacity,
                             int multiworkerOffset,
                             ActorProcessor<? super T>... processors)
Method Detail

getAvailable

public int getAvailable()
Specified by:
getAvailable in interface ActorQueueApi<T>

isEmpty

public boolean isEmpty()
Specified by:
isEmpty in interface ActorQueueApi<T>

getSize

public int getSize()
Specified by:
getSize in interface ActorQueueApi<T>

offer

public final void offer(T value)
Specified by:
offer in interface ActorQueueApi<T>

offer

public final boolean offer(T value,
                           boolean isWait)
Specified by:
offer in interface ActorQueueApi<T>

wake

public void wake()
Specified by:
wake in interface ActorQueueApi<T>

close

public void close()

toString

public java.lang.String toString()
Overrides:
toString in class java.lang.Object