Class TaskTideExecutorServiceProvider

java.lang.Object
org.tasktide.engine.workerunit.provider.TaskTideExecutorServiceProvider
public class TaskTideExecutorServiceProvider extends Object
Singleton class to provide the ExecutorService for WorkItem and ItemTask

  • Method Details

    • initialize

      public static void initialize(int engineWorkerThreads, int itemTaskThreads)
      Initialize executor services for provided pool sizes
      Parameters:
      engineWorkerThreads -
      itemTaskThreads -

    • getInstance

      public static TaskTideExecutorServiceProvider getInstance()
      Provides the executor if initialized
      Returns:
      TaskTideExecutorServiceProvider

    • getEngineWorkerExecutorService

      public ExecutorService getEngineWorkerExecutorService()
      Get configured ExecutorService for WorkItem processing
      Returns:
      ExecutorService

    • getItemTaskExecutorService

      public ExecutorService getItemTaskExecutorService()
      Get configured ExecutorService for ItemTask processing
      Returns:
      ExecutorService

    • engineWorkerExecutorService

      public static ExecutorService engineWorkerExecutorService()
      Static accessor for convenience for WorkItem exectuor service
      Returns:
      ExecutorService

    • itemTaskExecutorService

      public static ExecutorService itemTaskExecutorService()
      Static accessor for convenience for ItemTask exectuor service
      Returns:
      ExecutorService

    • getEngineWorkerThreads

      public int getEngineWorkerThreads()
      Thread pool size for WorkItem executor
      Returns:
      int

    • getItemTaskThreads

      public int getItemTaskThreads()
      Thread pool size for ItemTask executor
      Returns:
      int

    • isParallelized

      public boolean isParallelized()
      Checks whether service provider is parallelized
      Returns:
      boolean

    • reset

      public static void reset()
      Reset the engine worker unit container for testing