com.caucho.env.actor

Class MultiworkerActorQueue<T>

java.lang.Object

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

Constructors

Constructor and Description
MultiworkerActorQueue(int capacity, int multiworkerOffset, ActorProcessor<? super T>... processors)

Method Summary

Modifier and Type	Method and Description
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