org.apache.hadoop.hbase.procedure

Class SimpleRSProcedureManager.SimpleSubprocedurePool

java.lang.Object

org.apache.hadoop.hbase.procedure.SimpleRSProcedureManager.SimpleSubprocedurePool

All Implemented Interfaces:

Closeable, AutoCloseable, Abortable

Enclosing class:

SimpleRSProcedureManager

public class SimpleRSProcedureManager.SimpleSubprocedurePool
extends Object
implements Closeable, Abortable

Constructor Summary

Constructors

Constructor and Description
SimpleSubprocedurePool(String name, Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e) Abort the server or client.
void	close() Attempt to cleanly shutdown any running tasks - allows currently running tasks to cleanly finish
boolean	isAborted() Check if the server or client was aborted.
void	submitTask(Callable<Void> task) Submit a task to the pool.
boolean	waitForOutstandingTasks() Wait for all of the currently outstanding tasks submitted via submitTask(Callable)

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleSubprocedurePool

public SimpleSubprocedurePool(String name,
                              Configuration conf)

Method Detail

submitTask

public void submitTask(Callable<Void> task)

Submit a task to the pool.

waitForOutstandingTasks

public boolean waitForOutstandingTasks()
                                throws ForeignException

Wait for all of the currently outstanding tasks submitted via submitTask(Callable)

Returns:

true on success, false otherwise

Throws:

ForeignException

close

public void close()

Attempt to cleanly shutdown any running tasks - allows currently running tasks to cleanly finish

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

abort

public void abort(String why,
                  Throwable e)

Description copied from interface: Abortable

Abort the server or client.

Specified by:

abort in interface Abortable

Parameters:

why - Why we're aborting.

e - Throwable that caused abort. Can be null.

isAborted

public boolean isAborted()

Description copied from interface: Abortable

Check if the server or client was aborted.

Specified by:

isAborted in interface Abortable

Returns:

true if the server or client was aborted, false otherwise