ThreadingService (Esper API Documentation)

All Known Implementing Classes:

ThreadingServiceImpl
```
public interface ThreadingService
```
Engine-level threading services.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method and Description
`void`	`destroy()` Destroy thread pools.
`BlockingQueue<Runnable>`	`getInboundQueue()` Returns the inbound queue.
`ThreadPoolExecutor`	`getInboundThreadPool()` Returns the inbound thread pool
`BlockingQueue<Runnable>`	`getOutboundQueue()` Returns the outbound queue.
`ThreadPoolExecutor`	`getOutboundThreadPool()` Returns the outbound thread pool
`BlockingQueue<Runnable>`	`getRouteQueue()` Returns the route queue.
`ThreadPoolExecutor`	`getRouteThreadPool()` Returns the route thread pool
`BlockingQueue<Runnable>`	`getTimerQueue()` Returns the timer queue.
`ThreadPoolExecutor`	`getTimerThreadPool()` Returns the timer thread pool
`void`	`initThreading(EPServicesContext services, EPRuntimeImpl runtime)` Initialize thread pools.
`boolean`	`isInboundThreading()` Returns true for inbound threading enabled.
`boolean`	`isOutboundThreading()` Returns true for outbound threading enabled.
`boolean`	`isRouteThreading()` Returns true for route execution threading enabled.
`boolean`	`isTimerThreading()` Returns true for timer execution threading enabled.
`Thread`	`makeEventSourceThread(String engineURI, String sourceName, Runnable runnable)`
`void`	`submitInbound(InboundUnitRunnable unit)` Submit inbound work unit.
`void`	`submitOutbound(OutboundUnitRunnable unit)` Submit outbound work unit.
`void`	`submitRoute(RouteUnitRunnable unit)` Submit route work unit.
`void`	`submitTimerWork(TimerUnit timerUnit)` Submit timer execution work unit.

- Method Detail
  - destroy
```
void destroy()
```
    Destroy thread pools.
  - initThreading
```
void initThreading(EPServicesContext services,
                   EPRuntimeImpl runtime)
```
    Initialize thread pools.
    
    Parameters:
    
    services - engine-level service context
    
    runtime - runtime
  - isTimerThreading
```
boolean isTimerThreading()
```
    Returns true for timer execution threading enabled.
    
    Returns:
    
    indicator
  - submitTimerWork
```
void submitTimerWork(TimerUnit timerUnit)
```
    Submit timer execution work unit.
    
    Parameters:
    
    timerUnit - unit of work
  - isInboundThreading
```
boolean isInboundThreading()
```
    Returns true for inbound threading enabled.
    
    Returns:
    
    indicator
  - submitInbound
```
void submitInbound(InboundUnitRunnable unit)
```
    Submit inbound work unit.
    
    Parameters:
    
    unit - unit of work
  - isRouteThreading
```
boolean isRouteThreading()
```
    Returns true for route execution threading enabled.
    
    Returns:
    
    indicator
  - submitRoute
```
void submitRoute(RouteUnitRunnable unit)
```
    Submit route work unit.
    
    Parameters:
    
    unit - unit of work
  - isOutboundThreading
```
boolean isOutboundThreading()
```
    Returns true for outbound threading enabled.
    
    Returns:
    
    indicator
  - submitOutbound
```
void submitOutbound(OutboundUnitRunnable unit)
```
    Submit outbound work unit.
    
    Parameters:
    
    unit - unit of work
  - getOutboundQueue
```
BlockingQueue<Runnable> getOutboundQueue()
```
    Returns the outbound queue.
    
    Returns:
    
    queue
  - getOutboundThreadPool
```
ThreadPoolExecutor getOutboundThreadPool()
```
    Returns the outbound thread pool
    
    Returns:
    
    thread pool
  - getRouteQueue
```
BlockingQueue<Runnable> getRouteQueue()
```
    Returns the route queue.
    
    Returns:
    
    queue
  - getRouteThreadPool
```
ThreadPoolExecutor getRouteThreadPool()
```
    Returns the route thread pool
    
    Returns:
    
    thread pool
  - getTimerQueue
```
BlockingQueue<Runnable> getTimerQueue()
```
    Returns the timer queue.
    
    Returns:
    
    queue
  - getTimerThreadPool
```
ThreadPoolExecutor getTimerThreadPool()
```
    Returns the timer thread pool
    
    Returns:
    
    thread pool
  - getInboundQueue
```
BlockingQueue<Runnable> getInboundQueue()
```
    Returns the inbound queue.
    
    Returns:
    
    queue
  - getInboundThreadPool
```
ThreadPoolExecutor getInboundThreadPool()
```
    Returns the inbound thread pool
    
    Returns:
    
    thread pool
  - makeEventSourceThread
```
Thread makeEventSourceThread(String engineURI,
                             String sourceName,
                             Runnable runnable)
```

Interface ThreadingService

Method Summary

Method Detail

destroy

initThreading

isTimerThreading

submitTimerWork

isInboundThreading

submitInbound

isRouteThreading

submitRoute

isOutboundThreading

submitOutbound

getOutboundQueue

getOutboundThreadPool

getRouteQueue

getRouteThreadPool

getTimerQueue

getTimerThreadPool

getInboundQueue

getInboundThreadPool

makeEventSourceThread