com.hazelcast.elastic.queue

Class LongConcurrentLinkedQueue

java.lang.Object

com.hazelcast.elastic.queue.LongConcurrentLinkedQueue

All Implemented Interfaces:

LongQueue, GarbageCollectable, com.hazelcast.nio.Disposable

public final class LongConcurrentLinkedQueue
extends Object
implements LongQueue, GarbageCollectable

See http://www.cs.rochester.edu/u/scott/papers/1996_PODC_queues.pdf See ABA problem; http://en.wikipedia.org/wiki/ABA_problem

Constructor Summary

Constructors

Constructor and Description
LongConcurrentLinkedQueue(com.hazelcast.internal.memory.MemoryAllocator malloc, long nullValue)
LongConcurrentLinkedQueue(com.hazelcast.internal.memory.MemoryAllocator malloc, long nullValue, int threadLocalAddressCapacity)

Method Summary

Modifier and Type	Method and Description
int	capacity()
void	clear()
void	dispose()
void	gc()
boolean	isDestroyed()
boolean	isEmpty()
LongIterator	iterator()
long	nullItem()
boolean	offer(long value)
long	peek()
long	poll()
int	remainingCapacity()
int	size()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LongConcurrentLinkedQueue

public LongConcurrentLinkedQueue(com.hazelcast.internal.memory.MemoryAllocator malloc,
                                 long nullValue)

LongConcurrentLinkedQueue

public LongConcurrentLinkedQueue(com.hazelcast.internal.memory.MemoryAllocator malloc,
                                 long nullValue,
                                 int threadLocalAddressCapacity)

Method Detail

offer

public boolean offer(long value)

Specified by:

offer in interface LongQueue

poll

public long poll()

Specified by:

poll in interface LongQueue

peek

public long peek()

Specified by:

peek in interface LongQueue

size

public int size()

Specified by:

size in interface LongQueue

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface LongQueue

capacity

public int capacity()

Specified by:

capacity in interface LongQueue

remainingCapacity

public int remainingCapacity()

Specified by:

remainingCapacity in interface LongQueue

clear

public void clear()

Specified by:

clear in interface LongQueue

nullItem

public long nullItem()

Specified by:

nullItem in interface LongQueue

dispose

public void dispose()

Specified by:

dispose in interface com.hazelcast.nio.Disposable

isDestroyed

public boolean isDestroyed()

gc

public void gc()

Specified by:

gc in interface GarbageCollectable

iterator

public LongIterator iterator()

Specified by:

iterator in interface LongQueue

toString

public String toString()

Overrides:

toString in class Object