org.apache.hadoop.hbase.procedure2

Class ProcedureSimpleRunQueue

java.lang.Object

org.apache.hadoop.hbase.procedure2.ProcedureSimpleRunQueue

All Implemented Interfaces:

ProcedureRunnableSet

@InterfaceAudience.Private
 @InterfaceStability.Evolving
public class ProcedureSimpleRunQueue
extends Object
implements ProcedureRunnableSet

Simple runqueue for the procedures

Constructor Summary

Constructors

Constructor and Description
ProcedureSimpleRunQueue()

Method Summary

Modifier and Type	Method and Description
void	addBack(Procedure proc) Inserts the specified element at the end of this queue.
void	addFront(Procedure proc) Inserts the specified element at the front of this queue.
void	clear() Removes all of the elements from this collection.
void	completionCleanup(Procedure proc) The procedure in execution completed.
Long	poll() Fetch one Procedure from the queue
void	signalAll() In case the class is blocking on poll() waiting for items to be added, this method should awake poll() and poll() should return.
int	size() Returns the number of elements in this collection.
void	yield(Procedure proc) The procedure can't run at the moment.

Methods inherited from class java.lang.Object

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

Constructor Detail

ProcedureSimpleRunQueue

public ProcedureSimpleRunQueue()

Method Detail

addFront

public void addFront(Procedure proc)

Description copied from interface: ProcedureRunnableSet

Inserts the specified element at the front of this queue.

Specified by:

addFront in interface ProcedureRunnableSet

Parameters:

proc - the Procedure to add

addBack

public void addBack(Procedure proc)

Description copied from interface: ProcedureRunnableSet

Inserts the specified element at the end of this queue.

Specified by:

addBack in interface ProcedureRunnableSet

Parameters:

proc - the Procedure to add

yield

public void yield(Procedure proc)

Description copied from interface: ProcedureRunnableSet

The procedure can't run at the moment. add it back to the queue, giving priority to someone else.

Specified by:

yield in interface ProcedureRunnableSet

Parameters:

proc - the Procedure to add back to the list

poll

public Long poll()

Description copied from interface: ProcedureRunnableSet

Fetch one Procedure from the queue

Specified by:

poll in interface ProcedureRunnableSet

Returns:

the Procedure ID to execute, or null if nothing present.

signalAll

public void signalAll()

Description copied from interface: ProcedureRunnableSet

In case the class is blocking on poll() waiting for items to be added, this method should awake poll() and poll() should return.

Specified by:

signalAll in interface ProcedureRunnableSet

clear

public void clear()

Description copied from interface: ProcedureRunnableSet

Removes all of the elements from this collection.

Specified by:

clear in interface ProcedureRunnableSet

size

public int size()

Description copied from interface: ProcedureRunnableSet

Returns the number of elements in this collection.

Specified by:

size in interface ProcedureRunnableSet

Returns:

the number of elements in this collection.

completionCleanup

public void completionCleanup(Procedure proc)

Description copied from interface: ProcedureRunnableSet

The procedure in execution completed. This can be implemented to perform cleanups.

Specified by:

completionCleanup in interface ProcedureRunnableSet

Parameters:

proc - the Procedure that completed the execution.