Class WorkerPool<T>

  • Direct Known Subclasses:
    SingleWorkerPool

    public class WorkerPool<T>
    extends java.lang.Object
    • Constructor Detail

      • WorkerPool

        public WorkerPool​(java.lang.String poolName,
                          int corePoolSize,
                          int maximumPoolSize,
                          PoolSizeAdaptationStrategy adaptationStrategy,
                          WorkerFactory<T> workerFactory,
                          int queueSize,
                          boolean fair,
                          boolean daemon)
      • WorkerPool

        public WorkerPool​(java.lang.String poolName,
                          int corePoolSize,
                          int maximumPoolSize,
                          PoolSizeAdaptationStrategy adaptationStrategy,
                          WorkerFactory<T> workerFactory,
                          int queueSize,
                          boolean fair)
      • WorkerPool

        public WorkerPool​(java.lang.String poolName,
                          int corePoolSize,
                          int maximumPoolSize,
                          PoolSizeAdaptationStrategy adaptationStrategy,
                          WorkerFactory<T> workerFactory,
                          int queueSize)
    • Method Detail

      • getDefaultContextClassLoader

        public java.lang.ClassLoader getDefaultContextClassLoader()
      • setContextClassLoader

        public void setContextClassLoader​(java.lang.ClassLoader contextClassLoader)
      • setEventSource

        public void setEventSource​(java.lang.Object eventSource)
      • addWork

        public void addWork​(T work)
      • addWorkAndWait

        public void addWorkAndWait​(T work)
      • prestartCoreWorker

        public boolean prestartCoreWorker()
      • prestartCoreWorkers

        public int prestartCoreWorkers()
      • shutdown

        public void shutdown()
      • shutdownAndWait

        public void shutdownAndWait()
                             throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • shutdownNow

        public java.util.List<T> shutdownNow()
      • join

        public void join()
                  throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException
      • awaitQueueEmpty

        public void awaitQueueEmpty()
      • drainWorkQueue

        public java.util.List<T> drainWorkQueue()
      • getMaximumQueueSize

        public int getMaximumQueueSize()
      • setMaximumPoolSize

        public void setMaximumPoolSize​(int maximumPoolSize)
      • setCorePoolSize

        public void setCorePoolSize​(int corePoolSize)
      • getMaximumPoolSize

        public int getMaximumPoolSize()
      • getCorePoolSize

        public int getCorePoolSize()
      • isTerminated

        public boolean isTerminated()
      • isTerminating

        public boolean isTerminating()
      • getPoolSize

        public int getPoolSize()
      • getName

        public java.lang.String getName()