RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.procedure.flush.RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool

Enclosing class:

RegionServerFlushTableProcedureManager
```
static class RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool
extends Object
```
We use the FlushTableSubprocedurePool, a class specific thread pool instead of ExecutorService. It uses a ExecutorCompletionService which provides queuing of completed tasks which lets us efficiently cancel pending tasks upon the earliest operation failures.

Field Summary

Fields
Modifier and Type	Field and Description
`private Abortable`	`abortable`
`private ThreadPoolExecutor`	`executor`
`private List<Future<Void>>`	`futures`
`private String`	`name`
`private boolean`	`stopped`
`private ExecutorCompletionService<Void>`	`taskPool`

Constructor Summary

Constructors
Constructor and Description
`RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool(String name, org.apache.hadoop.conf.Configuration conf, Abortable abortable)`

Method Summary

Methods
Modifier and Type	Method and Description
`(package private) void`	`cancelTasks()` This attempts to cancel out all pending and in progress tasks.
`(package private) boolean`	`hasTasks()`
`(package private) void`	`stop()` Gracefully shutdown the thread pool.
`(package private) void`	`submitTask(Callable<Void> task)` Submit a task to the pool.
`(package private) 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

abortable
```
private final Abortable abortable
```

taskPool

private final ExecutorCompletionService<Void> taskPool

executor

private final ThreadPoolExecutor executor

stopped
```
private volatile boolean stopped
```

futures

private final List<Future<Void>> futures

name
```
private final String name
```

Constructor Detail

RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool

RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool(String name,
                                                                 org.apache.hadoop.conf.Configuration conf,
                                                                 Abortable abortable)

Method Detail
- hasTasks
```
boolean hasTasks()
```
- submitTask
```
void submitTask(Callable<Void> task)
```
  Submit a task to the pool. NOTE: all must be submitted before you can safely waitForOutstandingTasks().
- waitForOutstandingTasks
```
boolean waitForOutstandingTasks()
                          throws ForeignException,
                                 InterruptedException
```
  Wait for all of the currently outstanding tasks submitted via submitTask(Callable). This *must* be called after all tasks are submitted via submitTask.
  
  Returns:
  true on success, false otherwise
  
  Throws:
  
  InterruptedException
  
  ForeignException
- cancelTasks
```
void cancelTasks()
           throws InterruptedException
```
  This attempts to cancel out all pending and in progress tasks. Does not interrupt the running tasks itself. An ongoing HRegion.flush() should not be interrupted (see HBASE-13877).
  
  Throws:
  
  InterruptedException
- stop
```
void stop()
```
  Gracefully shutdown the thread pool. An ongoing HRegion.flush() should not be interrupted (see HBASE-13877)

Class RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

abortable

taskPool

executor

stopped

futures

name

Constructor Detail

RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool

Method Detail

hasTasks

submitTask

waitForOutstandingTasks

cancelTasks

stop