Package kilim.concurrent

Class SPSCQueue<T>

java.lang.Object

kilim.concurrent.SPSCQueue<T>

public class SPSCQueue<T>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SPSCQueue.PaddedLong

Field Summary

Fields

Modifier and Type	Field	Description
protected T[]	buffer
final VolatileLongCell	head
protected final SPSCQueue.PaddedLong	headCache
protected final int	mask
final VolatileLongCell	tail
protected final SPSCQueue.PaddedLong	tailCache

Constructor Summary

Constructors

Constructor	Description
SPSCQueue(int initialSize)

Method Summary

Modifier and Type	Method	Description
boolean	fillnb(T[] msg)
static int	findNextPositivePowerOfTwo(int value)
boolean	hasSpace()
boolean	isEmpty()
boolean	offer(T msg)
T	poll()
void	putMailbox(T[] buf, MailboxSPSC mb)
int	size()

Methods inherited from class java.lang.Object

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

Field Details

buffer

protected T[] buffer

tail

public final VolatileLongCell tail

head

public final VolatileLongCell head

mask

protected final int mask

tailCache

protected final SPSCQueue.PaddedLong tailCache

headCache

protected final SPSCQueue.PaddedLong headCache

Constructor Details

SPSCQueue

public SPSCQueue(int initialSize)

Method Details

findNextPositivePowerOfTwo

public static int findNextPositivePowerOfTwo(int value)

poll

public T poll()

offer

public boolean offer(T msg)

putMailbox

public void putMailbox(T[] buf,
 MailboxSPSC mb)
                throws Pausable

Throws:

Pausable

fillnb

public boolean fillnb(T[] msg)

isEmpty

public boolean isEmpty()

hasSpace

public boolean hasSpace()

size

public int size()