Class VitruvioThreadPoolWrapper

Object
VitruvioThreadPoolWrapper
All Implemented Interfaces:
ThreadPool

public class VitruvioThreadPoolWrapper extends Object implements ThreadPool
  • Field Details

    • logger

      protected final Log logger
      Logger available to subclasses
    • MIN_AVALIABLE_THREADS

      public static final int MIN_AVALIABLE_THREADS
      See Also:
  • Constructor Details

    • VitruvioThreadPoolWrapper

      public VitruvioThreadPoolWrapper()
  • Method Details

    • setInstanceId

      public void setInstanceId(String schedInstId)
      Specified by:
      setInstanceId in interface ThreadPool
    • setInstanceName

      public void setInstanceName(String schedName)
      Specified by:
      setInstanceName in interface ThreadPool
    • initialize

      public void initialize() throws SchedulerConfigException
      Specified by:
      initialize in interface ThreadPool
      Throws:
      SchedulerConfigException
    • shutdown

      public void shutdown(boolean waitForJobsToComplete)
      Specified by:
      shutdown in interface ThreadPool
    • getPoolSize

      public int getPoolSize()
      Specified by:
      getPoolSize in interface ThreadPool
    • runInThread

      public boolean runInThread(Runnable runnable)
      Specified by:
      runInThread in interface ThreadPool
    • blockForAvailableThreads

      public int blockForAvailableThreads()
      Specified by:
      blockForAvailableThreads in interface ThreadPool