public class SimpleRSProcedureManager.SimpleSubprocedurePool extends java.lang.Object implements java.io.Closeable, Abortable
Constructor and Description |
---|
SimpleSubprocedurePool(java.lang.String name,
Configuration conf) |
Modifier and Type | Method and Description |
---|---|
void |
abort(java.lang.String why,
java.lang.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(java.util.concurrent.Callable<java.lang.Void> task)
Submit a task to the pool.
|
boolean |
waitForOutstandingTasks()
Wait for all of the currently outstanding tasks submitted via
submitTask(Callable) |
public SimpleSubprocedurePool(java.lang.String name, Configuration conf)
public void submitTask(java.util.concurrent.Callable<java.lang.Void> task)
public boolean waitForOutstandingTasks() throws ForeignException
submitTask(Callable)
ForeignException
public void close()
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
public void abort(java.lang.String why, java.lang.Throwable e)
Abortable