Package 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 static class SimpleRSProcedureManager.SimpleSubprocedurePool
extends Object
implements Closeable, org.apache.hadoop.hbase.Abortable

Field Summary

Fields

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

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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

Methods inherited from interface org.apache.hadoop.hbase.Abortable

abort

Field Details

taskPool

private final ExecutorCompletionService<Void> taskPool

executor

private final ExecutorService executor

aborted

private volatile boolean aborted

futures

private final List<Future<Void>> futures

name

private final String name

Constructor Details

SimpleSubprocedurePool

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

Method Details

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 AutoCloseable

Specified by:

close in interface Closeable

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