co.paralleluniverse.strands.queues

Class CircularBuffer<E>

java.lang.Object

co.paralleluniverse.strands.queues.CircularBuffer<E>

All Implemented Interfaces:

BasicQueue<E>

Direct Known Subclasses:

CircularDoubleBuffer, CircularFloatBuffer, CircularIntBuffer, CircularLongBuffer, CircularObjectBuffer

public abstract class CircularBuffer<E>
extends java.lang.Object
implements BasicQueue<E>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CircularBuffer.Consumer

Method Summary

Modifier and Type	Method and Description
CircularBuffer.Consumer	builtinConsumer()
int	capacity()
abstract boolean	enq(E elem)
boolean	hasNext()
boolean	isEmpty()
boolean	isSingleProducer()
abstract CircularBuffer.Consumer	newConsumer()
E	poll()
int	size()

Methods inherited from class java.lang.Object

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

Method Detail

isSingleProducer

public boolean isSingleProducer()

builtinConsumer

public CircularBuffer.Consumer builtinConsumer()

capacity

public int capacity()

Specified by:

capacity in interface BasicQueue<E>

enq

public abstract boolean enq(E elem)

Specified by:

enq in interface BasicQueue<E>

poll

public E poll()

Specified by:

poll in interface BasicQueue<E>

size

public int size()

Specified by:

size in interface BasicQueue<E>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface BasicQueue<E>

hasNext

public boolean hasNext()

newConsumer

public abstract CircularBuffer.Consumer newConsumer()