com.espertech.esper.runtime.internal.kernel.thread

Class ThreadingServiceImpl

java.lang.Object

com.espertech.esper.runtime.internal.kernel.thread.ThreadingServiceImpl

All Implemented Interfaces:

com.espertech.esper.common.internal.statement.thread.ThreadingCommon, ThreadingService

public class ThreadingServiceImpl
extends Object
implements ThreadingService

Implementation for runtime-level threading.

Constructor Summary

Constructors

Constructor and Description
ThreadingServiceImpl(com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeThreading threadingConfig) Ctor.

Method Summary

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, EPEventServiceImpl 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 runtimeURI, String sourceName, Runnable runnable)
void	submitInbound(com.espertech.esper.common.client.EventBean event, com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped runtimeEventSender)
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 unit) Submit timer execution work unit.

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadingServiceImpl

public ThreadingServiceImpl(com.espertech.esper.common.client.configuration.runtime.ConfigurationRuntimeThreading threadingConfig)

Ctor.

Parameters:

threadingConfig - configuration

Method Detail

isRouteThreading

public boolean isRouteThreading()

Description copied from interface: ThreadingService

Returns true for route execution threading enabled.

Specified by:

isRouteThreading in interface ThreadingService

Returns:

indicator

isInboundThreading

public boolean isInboundThreading()

Description copied from interface: ThreadingService

Returns true for inbound threading enabled.

Specified by:

isInboundThreading in interface com.espertech.esper.common.internal.statement.thread.ThreadingCommon

Specified by:

isInboundThreading in interface ThreadingService

Returns:

indicator

isTimerThreading

public boolean isTimerThreading()

Description copied from interface: ThreadingService

Returns true for timer execution threading enabled.

Specified by:

isTimerThreading in interface ThreadingService

Returns:

indicator

isOutboundThreading

public boolean isOutboundThreading()

Description copied from interface: ThreadingService

Returns true for outbound threading enabled.

Specified by:

isOutboundThreading in interface ThreadingService

Returns:

indicator

initThreading

public void initThreading(EPServicesContext services,
                          EPEventServiceImpl runtime)

Description copied from interface: ThreadingService

Initialize thread pools.

Specified by:

initThreading in interface ThreadingService

Parameters:

services - runtime-level service context

runtime - runtime

submitRoute

public void submitRoute(RouteUnitRunnable unit)

Description copied from interface: ThreadingService

Submit route work unit.

Specified by:

submitRoute in interface ThreadingService

Parameters:

unit - unit of work

submitInbound

public void submitInbound(InboundUnitRunnable unit)

Description copied from interface: ThreadingService

Submit inbound work unit.

Specified by:

submitInbound in interface ThreadingService

Parameters:

unit - unit of work

submitOutbound

public void submitOutbound(OutboundUnitRunnable unit)

Description copied from interface: ThreadingService

Submit outbound work unit.

Specified by:

submitOutbound in interface ThreadingService

Parameters:

unit - unit of work

submitTimerWork

public void submitTimerWork(TimerUnit unit)

Description copied from interface: ThreadingService

Submit timer execution work unit.

Specified by:

submitTimerWork in interface ThreadingService

Parameters:

unit - unit of work

getOutboundQueue

public BlockingQueue<Runnable> getOutboundQueue()

Description copied from interface: ThreadingService

Returns the outbound queue.

Specified by:

getOutboundQueue in interface ThreadingService

Returns:

queue

getOutboundThreadPool

public ThreadPoolExecutor getOutboundThreadPool()

Description copied from interface: ThreadingService

Returns the outbound thread pool

Specified by:

getOutboundThreadPool in interface ThreadingService

Returns:

thread pool

getRouteQueue

public BlockingQueue<Runnable> getRouteQueue()

Description copied from interface: ThreadingService

Returns the route queue.

Specified by:

getRouteQueue in interface ThreadingService

Returns:

queue

getRouteThreadPool

public ThreadPoolExecutor getRouteThreadPool()

Description copied from interface: ThreadingService

Returns the route thread pool

Specified by:

getRouteThreadPool in interface ThreadingService

Returns:

thread pool

getTimerQueue

public BlockingQueue<Runnable> getTimerQueue()

Description copied from interface: ThreadingService

Returns the timer queue.

Specified by:

getTimerQueue in interface ThreadingService

Returns:

queue

getTimerThreadPool

public ThreadPoolExecutor getTimerThreadPool()

Description copied from interface: ThreadingService

Returns the timer thread pool

Specified by:

getTimerThreadPool in interface ThreadingService

Returns:

thread pool

getInboundQueue

public BlockingQueue<Runnable> getInboundQueue()

Description copied from interface: ThreadingService

Returns the inbound queue.

Specified by:

getInboundQueue in interface ThreadingService

Returns:

queue

getInboundThreadPool

public ThreadPoolExecutor getInboundThreadPool()

Description copied from interface: ThreadingService

Returns the inbound thread pool

Specified by:

getInboundThreadPool in interface ThreadingService

Returns:

thread pool

destroy

public void destroy()

Description copied from interface: ThreadingService

Destroy thread pools.

Specified by:

destroy in interface ThreadingService

makeEventSourceThread

public Thread makeEventSourceThread(String runtimeURI,
                                    String sourceName,
                                    Runnable runnable)

Specified by:

makeEventSourceThread in interface ThreadingService

submitInbound

public void submitInbound(com.espertech.esper.common.client.EventBean event,
                          com.espertech.esper.common.internal.event.util.EPRuntimeEventProcessWrapped runtimeEventSender)

Specified by:

submitInbound in interface com.espertech.esper.common.internal.statement.thread.ThreadingCommon