org.apache.hadoop.hbase.procedure.flush

Class RegionServerFlushTableProcedureManager.FlushTableSubprocedurePool

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
FlushTableSubprocedurePool(String name, org.apache.hadoop.conf.Configuration conf, Abortable abortable)

Method Summary

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

FlushTableSubprocedurePool

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 n

Throws:

ForeignException

InterruptedException

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). n

Throws:

InterruptedException

stop

void stop()

Gracefully shutdown the thread pool. An ongoing HRegion.flush() should not be interrupted (see HBASE-13877)