Package kilim.concurrent

Class MPSCQueue<E>

java.lang.Object

kilim.concurrent.MPSCQueueL0Pad

kilim.concurrent.MPSCQueueColdFields<E>

kilim.concurrent.MPSCQueueL1Pad<E>

kilim.concurrent.MPSCQueueTailField<E>

kilim.concurrent.MPSCQueueL2Pad<E>

kilim.concurrent.MPSCQueueHeadField<E>

kilim.concurrent.MPSCQueueL3Pad<E>

kilim.concurrent.MPSCQueue<E>

public class MPSCQueue<E>
extends MPSCQueueL3Pad<E>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MPSCQueue.BackOffStrategy

Field Summary

Fields

Modifier and Type	Field	Description
private static MPSCQueue.BackOffStrategy	CAS_BACKOFF

Fields inherited from class kilim.concurrent.MPSCQueueL3Pad

ARRAY_BASE, ELEMENT_SHIFT, HEAD_OFFSET, p30, p31, p32, p33, p34, p35, p36, p37, p40, p41, p42, p43, p44, p45, p46, TAIL_OFFSET

Fields inherited from class kilim.concurrent.MPSCQueueHeadField

head

Fields inherited from class kilim.concurrent.MPSCQueueL2Pad

p20, p21, p22, p23, p24, p25, p26

Fields inherited from class kilim.concurrent.MPSCQueueTailField

tail

Fields inherited from class kilim.concurrent.MPSCQueueL1Pad

p10, p11, p12, p13, p14, p15, p16

Fields inherited from class kilim.concurrent.MPSCQueueColdFields

buffer, BUFFER_PAD, capacity, mask, SPARSE_SHIFT

Fields inherited from class kilim.concurrent.MPSCQueueL0Pad

p00, p01, p02, p03, p04, p05, p06, p07

Constructor Summary

Constructors

Constructor	Description
MPSCQueue(int capacity)

Method Summary

Modifier and Type	Method	Description
boolean	add(E e)
private boolean	casTail(long expect, long newValue)
E	element()
private long	elementOffsetInBuffer(long index)
void	fill(E[] buf)
private E	getElement(long index)
private long	getHead()
private long	getTail()
boolean	hasSpace()
boolean	isEmpty()
private void	lazySetHead(long l)
boolean	offer(E e)
E	peek()
E	poll()
E	remove()
int	size()

Methods inherited from class kilim.concurrent.MPSCQueueColdFields

findNextPositivePowerOfTwo, isPowerOf2

Methods inherited from class java.lang.Object

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

Field Detail

CAS_BACKOFF

private static final MPSCQueue.BackOffStrategy CAS_BACKOFF

Constructor Detail

MPSCQueue

public MPSCQueue(int capacity)

Method Detail

getHead

private long getHead()

lazySetHead

private void lazySetHead(long l)

getTail

private long getTail()

casTail

private boolean casTail(long expect,
                        long newValue)

add

public boolean add(E e)

elementOffsetInBuffer

private long elementOffsetInBuffer(long index)

offer

public boolean offer(E e)

hasSpace

public boolean hasSpace()

poll

public E poll()

fill

public void fill(E[] buf)

remove

public E remove()

isEmpty

public boolean isEmpty()

element

public E element()

peek

public E peek()

getElement

private E getElement(long index)

size

public int size()