com.caucho.util

Class RingValueQueue<M>

java.lang.Object

com.caucho.util.AbstractActorQueue<M>

com.caucho.util.RingValueQueue<M>

All Implemented Interfaces:

ActorQueue<M>, java.lang.Iterable<M>, java.util.Collection<M>, java.util.concurrent.BlockingQueue<M>, java.util.Queue<M>

public final class RingValueQueue<M>
extends AbstractActorQueue<M>

Value queue with atomic reference.

Constructor Summary

Constructors

Constructor and Description
RingValueQueue(int capacity)
RingValueQueue(int capacity, RingBlocker blocker)

Method Summary

Modifier and Type	Method and Description
void	close()
void	closeWrite()
int	getCapacity()
long	getHead()
long	getHeadAlloc()
int	getOfferReserve()
TaskWorker	getOfferTask()
long	getTail()
M	getValue(long ptr)
boolean	isEmpty()
boolean	isWriteClosed()
boolean	offer(M value, long timeout, java.util.concurrent.TimeUnit unit)
boolean	offer(M value, long timeout, java.util.concurrent.TimeUnit unit, int reservedSpace)
M	peek()
M	poll(long timeout, java.util.concurrent.TimeUnit unit)
int	remainingCapacity()
int	size()
java.lang.String	toString()
void	wake()

Methods inherited from class com.caucho.util.AbstractActorQueue

add, addAll, clear, contains, containsAll, drainTo, drainTo, element, iterator, offer, poll, put, remove, remove, removeAll, retainAll, take, toArray, toArray

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.Collection

equals, hashCode, parallelStream, removeIf, spliterator, stream

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

RingValueQueue

public RingValueQueue(int capacity)

RingValueQueue

public RingValueQueue(int capacity,
                      RingBlocker blocker)

Method Detail

getCapacity

public int getCapacity()

getOfferReserve

public int getOfferReserve()

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface java.util.concurrent.BlockingQueue<M>

Overrides:

remainingCapacity in class AbstractActorQueue<M>

isEmpty

public final boolean isEmpty()

Specified by:

isEmpty in interface java.util.Collection<M>

Overrides:

isEmpty in class AbstractActorQueue<M>

size

public final int size()

Specified by:

size in interface java.util.Collection<M>

Overrides:

size in class AbstractActorQueue<M>

getHead

public final long getHead()

getHeadAlloc

public final long getHeadAlloc()

getTail

public final long getTail()

getOfferTask

public TaskWorker getOfferTask()

getValue

public final M getValue(long ptr)

offer

public final boolean offer(M value,
                           long timeout,
                           java.util.concurrent.TimeUnit unit)

Specified by:

offer in interface java.util.concurrent.BlockingQueue<M>

Overrides:

offer in class AbstractActorQueue<M>

offer

public final boolean offer(M value,
                           long timeout,
                           java.util.concurrent.TimeUnit unit,
                           int reservedSpace)

Specified by:

offer in interface ActorQueue<M>

Overrides:

offer in class AbstractActorQueue<M>

poll

public final M poll(long timeout,
                    java.util.concurrent.TimeUnit unit)

Specified by:

poll in interface java.util.concurrent.BlockingQueue<M>

Overrides:

poll in class AbstractActorQueue<M>

peek

public final M peek()

Specified by:

peek in interface java.util.Queue<M>

Overrides:

peek in class AbstractActorQueue<M>

wake

public void wake()

isWriteClosed

public final boolean isWriteClosed()

closeWrite

public final void closeWrite()

close

public final void close()

toString

public java.lang.String toString()

Overrides:

toString in class AbstractActorQueue<M>