com.hazelcast.spi.impl.operationexecutor.impl

Class OperationQueueImpl

java.lang.Object

com.hazelcast.spi.impl.operationexecutor.impl.OperationQueueImpl

All Implemented Interfaces:

OperationQueue

public final class OperationQueueImpl
extends Object
implements OperationQueue

Constructor Summary

Constructors

Constructor and Description
OperationQueueImpl()
OperationQueueImpl(BlockingQueue<Object> normalQueue, Queue<Object> priorityQueue)

Method Summary

Modifier and Type	Method and Description
void	add(Object task, boolean priority) Adds an task to this queue.
int	normalSize() returns the number of normal operations pending.
int	prioritySize() returns the number of priority operations pending.
int	size() Returns the total number of pending operations.
Object	take(boolean priorityOnly) Takes an item from this queue.

Methods inherited from class java.lang.Object

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

Constructor Detail

OperationQueueImpl

public OperationQueueImpl()

OperationQueueImpl

public OperationQueueImpl(BlockingQueue<Object> normalQueue,
                          Queue<Object> priorityQueue)

Method Detail

normalSize

public int normalSize()

Description copied from interface: OperationQueue

returns the number of normal operations pending. This method is thread safe. This method returns a best effort value and should only be used for monitoring purposes.

Specified by:

normalSize in interface OperationQueue

Returns:

the number of normal pending operations.

prioritySize

public int prioritySize()

Description copied from interface: OperationQueue

returns the number of priority operations pending. This method is thread safe. This method returns a best effort value and should only be used for monitoring purposes.

Specified by:

prioritySize in interface OperationQueue

Returns:

the number of priority pending operations.

size

public int size()

Description copied from interface: OperationQueue

Returns the total number of pending operations. This method is thread safe. This method returns a best effort value and should only be used for monitoring purposes.

Specified by:

size in interface OperationQueue

Returns:

the total number of pending operations.

add

public void add(Object task,
                boolean priority)

Description copied from interface: OperationQueue

Adds an task to this queue. This method is thread safe.

Specified by:

add in interface OperationQueue

Parameters:

task - the item to add

priority - if the task has priority or not

take

public Object take(boolean priorityOnly)
            throws InterruptedException

Description copied from interface: OperationQueue

Takes an item from this queue. If no item is available, the call blocks. This method should always be called by the same thread.

Specified by:

take in interface OperationQueue

Parameters:

priorityOnly - true if only priority items should be taken. This is useful for priority generic threads since they should only take priority items.

Returns:

the taken item.

Throws:

InterruptedException - if the thread is interrupted while waiting.