co.paralleluniverse.strands.queues

Class CircularObjectBuffer<E>

java.lang.Object

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

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

All Implemented Interfaces:

BasicQueue<E>

public class CircularObjectBuffer<E>
extends CircularBuffer<E>

Nested Class Summary

Nested classes/interfaces inherited from class co.paralleluniverse.strands.queues.CircularBuffer

CircularBuffer.Consumer

Constructor Summary

Constructors

Constructor and Description
CircularObjectBuffer(int size, boolean singleProducer)

Method Summary

Modifier and Type	Method and Description
boolean	enq(E elem)
CircularBuffer.Consumer	newConsumer()

Methods inherited from class co.paralleluniverse.strands.queues.CircularBuffer

builtinConsumer, capacity, hasNext, isEmpty, isSingleProducer, poll, size

Methods inherited from class java.lang.Object

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

Constructor Detail

CircularObjectBuffer

public CircularObjectBuffer(int size,
                            boolean singleProducer)

Method Detail

enq

public boolean enq(E elem)

Specified by:

enq in interface BasicQueue<E>

Specified by:

enq in class CircularBuffer<E>

newConsumer

public CircularBuffer.Consumer newConsumer()

Specified by:

newConsumer in class CircularBuffer<E>