ExecutorService (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.executor.ExecutorService

```
@InterfaceAudience.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("myService");. When done call shutdown().
In order to use the service created above, call submit(EventHandler). Register pre- and post- processing listeners by registering your implementation of EventHandler.EventHandlerListener with registerListener(EventType, EventHandler.EventHandlerListener). Be sure to deregister your listener when done via unregisterListener(EventType).

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`(package private) static class`	`ExecutorService.Executor` Executor instance.
`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 and Description
`private ConcurrentHashMap<EventType,EventHandler.EventHandlerListener>`	`eventHandlerListeners`
`private ConcurrentHashMap<String,ExecutorService.Executor>`	`executorMap`
`private static org.apache.commons.logging.Log`	`LOG`
`private String`	`servername`

Constructor Summary

Constructors
Constructor and Description

ExecutorService(String servername)
Default constructor.

Constructors
Constructor and Description
`ExecutorService(String servername)` Default constructor.

Method Summary

Methods
Modifier and Type	Method and Description
`Map<String,ExecutorService.ExecutorStatus>`	`getAllExecutorStatuses()`
`(package private) ExecutorService.Executor`	`getExecutor(ExecutorType type)`
`(package private) ExecutorService.Executor`	`getExecutor(String name)`
`(package private) boolean`	`isExecutorServiceRunning(String name)`
`void`	`registerListener(EventType type, EventHandler.EventHandlerListener listener)` Subscribe to updates before and after processing instances of `EventType`.
`void`	`shutdown()`
`void`	`startExecutorService(ExecutorType type, int maxThreads)`
`(package private) void`	`startExecutorService(String name, int maxThreads)` Start an executor service with a given name.
`void`	`submit(EventHandler eh)`
`EventHandler.EventHandlerListener`	`unregisterListener(EventType type)` Stop receiving updates before and after processing instances of `EventType`

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

executorMap

private final ConcurrentHashMap<String,ExecutorService.Executor> executorMap

eventHandlerListeners

private ConcurrentHashMap<EventType,EventHandler.EventHandlerListener> eventHandlerListeners

servername
```
private final String servername
```

Constructor Detail
- ExecutorService
```
public ExecutorService(String servername)
```
  Default constructor.
  
  Parameters:
  servername - Name of the hosting server.

Method Detail
- startExecutorService
```
void startExecutorService(String name,
                        int maxThreads)
```
  Start an executor service with a given name. If there was a service already started with the same name, this throws a RuntimeException.
  
  Parameters:
  name - Name of the service to start.
- isExecutorServiceRunning
```
boolean isExecutorServiceRunning(String name)
```
- shutdown
```
public void shutdown()
```
- getExecutor
```
ExecutorService.Executor getExecutor(ExecutorType type)
```
- getExecutor
```
ExecutorService.Executor getExecutor(String name)
```
- startExecutorService
```
public void startExecutorService(ExecutorType type,
                        int maxThreads)
```
- submit
```
public void submit(EventHandler eh)
```
- registerListener
```
public void registerListener(EventType type,
                    EventHandler.EventHandlerListener listener)
```
  Subscribe to updates before and after processing instances of EventType. Currently only one listener per event type.
  
  Parameters:
  type - Type of event we're registering listener for
  listener - The listener to run.
- unregisterListener
```
public EventHandler.EventHandlerListener unregisterListener(EventType type)
```
  Stop receiving updates before and after processing instances of EventType
  
  Parameters:
  type - Type of event we're registering listener for
  
  Returns:
  The listener we removed or null if we did not remove it.
- getAllExecutorStatuses
```
public Map<String,ExecutorService.ExecutorStatus> getAllExecutorStatuses()
```

Class ExecutorService

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

LOG

executorMap

eventHandlerListeners

servername

Constructor Detail

ExecutorService

Method Detail

startExecutorService

isExecutorServiceRunning

shutdown

getExecutor

getExecutor

startExecutorService

submit

registerListener

unregisterListener

getAllExecutorStatuses