Package org.apache.hadoop.hbase.executor

Class ExecutorService

java.lang.Object

org.apache.hadoop.hbase.executor.ExecutorService

@Private
public class ExecutorService
extends Object

This is a generic executor service. This component abstracts a threadpool, a queue to which EventTypes can be submitted, and a Runnable that handles the object that is added to the queue.

In order to create a new service, create an instance of this class and then do: instance.startExecutorService(executorConfig);. ExecutorService.ExecutorConfig wraps the configuration needed by this service. When done call shutdown().

In order to use the service created above, call submit(EventHandler).

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ExecutorService.Executor	Executor instance.
class	ExecutorService.ExecutorConfig	Configuration wrapper for ExecutorService.Executor.
static class	ExecutorService.ExecutorStatus	A snapshot of the status of a particular executor.
static class	ExecutorService.RunningEventStatus	The status of a particular event that is in the middle of being handled by an executor.
(package private) static class	ExecutorService.TrackingThreadPoolExecutor	A subclass of ThreadPoolExecutor that keeps track of the Runnables that are executing at any given point in time.

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.hbase.thirdparty.com.google.common.util.concurrent.ListeningScheduledExecutorService	delayedSubmitTimer
private final ConcurrentMap<String,ExecutorService.Executor>	executorMap
private static final org.slf4j.Logger	LOG
private final String	servername

Constructor Summary

Constructors

Constructor	Description
ExecutorService(String servername)	Default constructor.

Method Summary

Modifier and Type	Method	Description
void	delayedSubmit(EventHandler eh, long delay, TimeUnit unit)
Map<String,ExecutorService.ExecutorStatus>	getAllExecutorStatuses()
(package private) ExecutorService.Executor	getExecutor(String name)
(package private) ExecutorService.Executor	getExecutor(ExecutorType type)
ThreadPoolExecutor	getExecutorLazily(ExecutorService.ExecutorConfig config)	Initialize the executor lazily, Note if an executor need to be initialized lazily, then all paths should use this method to get the executor, should not start executor by using startExecutorService(ExecutorConfig)
ThreadPoolExecutor	getExecutorThreadPool(ExecutorType type)
(package private) boolean	isExecutorServiceRunning(String name)
void	shutdown()
void	startExecutorService(ExecutorService.ExecutorConfig config)	Start an executor service with a given name.
void	submit(EventHandler eh)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

LOG

private static final org.slf4j.Logger LOG

executorMap

private final ConcurrentMap<String,ExecutorService.Executor> executorMap

servername

private final String servername

delayedSubmitTimer

private final org.apache.hbase.thirdparty.com.google.common.util.concurrent.ListeningScheduledExecutorService delayedSubmitTimer

Constructor Details

ExecutorService

public ExecutorService(String servername)

Default constructor.

Parameters:

servername - Name of the hosting server.

Method Details

startExecutorService

public void startExecutorService(ExecutorService.ExecutorConfig config)

Start an executor service with a given name. If there was a service already started with the same name, this throws a RuntimeException.

Parameters:

config - Configuration to use for the executor.

isExecutorServiceRunning

boolean isExecutorServiceRunning(String name)

shutdown

public void shutdown()

getExecutor

ExecutorService.Executor getExecutor(ExecutorType type)

getExecutor

ExecutorService.Executor getExecutor(String name)

getExecutorThreadPool

public ThreadPoolExecutor getExecutorThreadPool(ExecutorType type)

getExecutorLazily

public ThreadPoolExecutor getExecutorLazily(ExecutorService.ExecutorConfig config)

Initialize the executor lazily, Note if an executor need to be initialized lazily, then all paths should use this method to get the executor, should not start executor by using startExecutorService(ExecutorConfig)

submit

public void submit(EventHandler eh)

delayedSubmit

public void delayedSubmit(EventHandler eh,
 long delay,
 TimeUnit unit)

getAllExecutorStatuses

public Map<String,ExecutorService.ExecutorStatus> getAllExecutorStatuses()