co.paralleluniverse.strands.queues

Class CircularIntBuffer

java.lang.Object

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

co.paralleluniverse.strands.queues.CircularIntBuffer

All Implemented Interfaces:

BasicQueue<java.lang.Integer>, BasicSingleConsumerIntQueue, BasicSingleConsumerQueue<java.lang.Integer>

public class CircularIntBuffer
extends CircularBuffer<E>
implements BasicSingleConsumerIntQueue

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	CircularIntBuffer.IntConsumer

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

CircularBuffer.Consumer

Constructor Summary

Constructors

Constructor and Description
CircularIntBuffer(int size, boolean singleProducer)

Method Summary

Modifier and Type	Method and Description
boolean	enq(int elem)
boolean	enq(java.lang.Integer elem)
CircularIntBuffer.IntConsumer	newConsumer()
int	pollInt()

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

Methods inherited from interface co.paralleluniverse.strands.queues.BasicSingleConsumerQueue

hasNext

Methods inherited from interface co.paralleluniverse.strands.queues.BasicQueue

capacity, isEmpty, poll, size

Constructor Detail

CircularIntBuffer

public CircularIntBuffer(int size,
                         boolean singleProducer)

Method Detail

enq

public boolean enq(java.lang.Integer elem)

Specified by:

enq in interface BasicQueue<java.lang.Integer>

Specified by:

enq in class CircularBuffer<java.lang.Integer>

enq

public boolean enq(int elem)

Specified by:

enq in interface BasicSingleConsumerIntQueue

pollInt

public int pollInt()

Specified by:

pollInt in interface BasicSingleConsumerIntQueue

newConsumer

public CircularIntBuffer.IntConsumer newConsumer()

Specified by:

newConsumer in class CircularBuffer<java.lang.Integer>