Package kilim.concurrent

Class SPSCQueue<T>

java.lang.Object

kilim.concurrent.SPSCQueue<T>

public class SPSCQueue<T>
extends java.lang.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
VolatileLongCell	head
protected SPSCQueue.PaddedLong	headCache
protected int	mask
VolatileLongCell	tail
protected 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 Detail

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 Detail

SPSCQueue

public SPSCQueue(int initialSize)

Method Detail

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()