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

Interface ThreadingService

All Superinterfaces:
com.espertech.esper.common.internal.statement.thread.ThreadingCommon
All Known Implementing Classes:
ThreadingServiceImpl
public interface ThreadingService extends com.espertech.esper.common.internal.statement.thread.ThreadingCommon
Engine-level threading services.

  • Method Details

    • destroy

      void destroy()
      Destroy thread pools.

    • initThreading

      void initThreading(String uri, EPServicesEvaluation services)
      Initialize thread pools.
      Parameters:
      uri - uri
      services - services

    • 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.
      Specified by:
      isInboundThreading in interface com.espertech.esper.common.internal.statement.thread.ThreadingCommon
      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 runtimeURI, String sourceName, Runnable runnable)