com.espertech.esper.core.thread
Interface ThreadingService

All Known Implementing Classes:

ThreadingServiceImpl

public interface ThreadingService

Engine-level threading services.

Method Summary

void	destroy() Destroy thread pools.
java.util.concurrent.BlockingQueue<java.lang.Runnable>	getInboundQueue() Returns the inbound queue.
java.util.concurrent.ThreadPoolExecutor	getInboundThreadPool() Returns the inbound thread pool
java.util.concurrent.BlockingQueue<java.lang.Runnable>	getOutboundQueue() Returns the outbound queue.
java.util.concurrent.ThreadPoolExecutor	getOutboundThreadPool() Returns the outbound thread pool
java.util.concurrent.BlockingQueue<java.lang.Runnable>	getRouteQueue() Returns the route queue.
java.util.concurrent.ThreadPoolExecutor	getRouteThreadPool() Returns the route thread pool
java.util.concurrent.BlockingQueue<java.lang.Runnable>	getTimerQueue() Returns the timer queue.
java.util.concurrent.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.
java.lang.Thread	makeEventSourceThread(java.lang.String engineURI, java.lang.String sourceName, java.lang.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

java.util.concurrent.BlockingQueue<java.lang.Runnable> getOutboundQueue()

Returns the outbound queue.

Returns:

queue

getOutboundThreadPool

java.util.concurrent.ThreadPoolExecutor getOutboundThreadPool()

Returns the outbound thread pool

Returns:

thread pool

getRouteQueue

java.util.concurrent.BlockingQueue<java.lang.Runnable> getRouteQueue()

Returns the route queue.

Returns:

queue

getRouteThreadPool

java.util.concurrent.ThreadPoolExecutor getRouteThreadPool()

Returns the route thread pool

Returns:

thread pool

getTimerQueue

java.util.concurrent.BlockingQueue<java.lang.Runnable> getTimerQueue()

Returns the timer queue.

Returns:

queue

getTimerThreadPool

java.util.concurrent.ThreadPoolExecutor getTimerThreadPool()

Returns the timer thread pool

Returns:

thread pool

getInboundQueue

java.util.concurrent.BlockingQueue<java.lang.Runnable> getInboundQueue()

Returns the inbound queue.

Returns:

queue

getInboundThreadPool

java.util.concurrent.ThreadPoolExecutor getInboundThreadPool()

Returns the inbound thread pool

Returns:

thread pool

makeEventSourceThread

java.lang.Thread makeEventSourceThread(java.lang.String engineURI,
                                       java.lang.String sourceName,
                                       java.lang.Runnable runnable)