com.hazelcast.elastic.queue

Class LongArrayBlockingQueue

java.lang.Object

com.hazelcast.elastic.queue.LongArrayBlockingQueue

All Implemented Interfaces:

LongBlockingQueue, LongQueue, com.hazelcast.nio.Disposable

public final class LongArrayBlockingQueue
extends Object
implements LongBlockingQueue

Implementation of LongBlockingQueue with an off-heap array.

Constructor Summary

Constructors

Constructor and Description
LongArrayBlockingQueue(com.hazelcast.internal.memory.MemoryAllocator memoryAllocator, int capacity, long nullItem)

Method Summary

Modifier and Type	Method and Description
int	capacity()
void	clear()
void	consume(LongConsumer consumer)
void	dispose()
boolean	isEmpty()
LongIterator	iterator()
long	nullItem()
boolean	offer(long value)
boolean	offer(long value, long timeout, TimeUnit unit)
long	peek()
long	poll()
long	poll(long timeout, TimeUnit unit)
void	put(long value)
int	remainingCapacity()
int	size()
long	take()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

LongArrayBlockingQueue

public LongArrayBlockingQueue(com.hazelcast.internal.memory.MemoryAllocator memoryAllocator,
                              int capacity,
                              long nullItem)

Method Detail

offer

public boolean offer(long value)

Specified by:

offer in interface LongQueue

offer

public boolean offer(long value,
                     long timeout,
                     TimeUnit unit)
              throws InterruptedException

Specified by:

offer in interface LongBlockingQueue

Throws:

InterruptedException

put

public void put(long value)
         throws InterruptedException

Specified by:

put in interface LongBlockingQueue

Throws:

InterruptedException

peek

public long peek()

Specified by:

peek in interface LongQueue

poll

public long poll()

Specified by:

poll in interface LongQueue

poll

public long poll(long timeout,
                 TimeUnit unit)
          throws InterruptedException

Specified by:

poll in interface LongBlockingQueue

Throws:

InterruptedException

take

public long take()
          throws InterruptedException

Specified by:

take in interface LongBlockingQueue

Throws:

InterruptedException

consume

public void consume(LongConsumer consumer)

Specified by:

consume in interface LongBlockingQueue

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

dispose

public void dispose()

Specified by:

dispose in interface com.hazelcast.nio.Disposable

nullItem

public long nullItem()

Specified by:

nullItem in interface LongQueue

iterator

public LongIterator iterator()

Specified by:

iterator in interface LongQueue

toString

public String toString()

Overrides:

toString in class Object