org.apache.hadoop.hbase.procedure

Class SimpleRSProcedureManager.SimpleSubprocedurePool

java.lang.Object

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

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.Abortable

Enclosing class:

SimpleRSProcedureManager

public class SimpleRSProcedureManager.SimpleSubprocedurePool
extends Object
implements Closeable, org.apache.hadoop.hbase.Abortable

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	aborted
private ThreadPoolExecutor	executor
private List<Future<Void>>	futures
private String	name
private ExecutorCompletionService<Void>	taskPool

Constructor Summary

Constructors

Constructor and Description
SimpleSubprocedurePool(String name, org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	abort(String why, Throwable e)
void	close() Attempt to cleanly shutdown any running tasks - allows currently running tasks to cleanly finish
boolean	isAborted()
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

Field Detail

taskPool

private final ExecutorCompletionService<Void> taskPool

executor

private final ThreadPoolExecutor executor

aborted

private volatile boolean aborted

futures

private final List<Future<Void>> futures

name

private final String name

Constructor Detail

SimpleSubprocedurePool

public SimpleSubprocedurePool(String name,
                              org.apache.hadoop.conf.Configuration conf)

Method Detail

submitTask

public void submitTask(Callable<Void> task)

Submit a task to the pool.

waitForOutstandingTasks

public boolean waitForOutstandingTasks()
                                throws org.apache.hadoop.hbase.errorhandling.ForeignException

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

Returns:

true on success, false otherwise

Throws:

org.apache.hadoop.hbase.errorhandling.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)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.apache.hadoop.hbase.Abortable