Class NativeWorkerPool

  • All Implemented Interfaces:
    WorkerPool

    public class NativeWorkerPool
    extends Object
    implements WorkerPool
    Worker pool implementation based on java.util.concurrent in JDK 1.5 or later.
    • Constructor Detail

      • NativeWorkerPool

        public NativeWorkerPool​(int core,
                                int max,
                                int keepAlive,
                                int queueLength,
                                String threadGroupName,
                                String threadGroupId)
      • NativeWorkerPool

        public NativeWorkerPool​(int core,
                                int max,
                                int keepAlive,
                                int queueLength,
                                String threadGroupName,
                                String threadGroupId,
                                BlockingQueue<Runnable> queue)
      • NativeWorkerPool

        public NativeWorkerPool​(int core,
                                int max,
                                int keepAlive,
                                int queueLength,
                                int waterMark,
                                String threadGroupName,
                                String threadGroupId)
      • NativeWorkerPool

        public NativeWorkerPool​(int core,
                                int max,
                                int keepAlive,
                                int queueLength,
                                int waterMark,
                                String threadGroupName,
                                String threadGroupId,
                                WaterMarkQueue<Runnable> queue)
      • NativeWorkerPool

        public NativeWorkerPool​(int core,
                                int max,
                                int keepAlive,
                                int queueLength,
                                int waterMark,
                                String threadGroupName,
                                String threadGroupId,
                                RejectedExecutionHandler rejectedExecutionHandler)
    • Method Detail

      • execute

        public void execute​(Runnable task)
        Description copied from interface: WorkerPool
        Asynchronously execute the given task using one of the threads of the worker pool. The task is expected to terminate gracefully, i.e. Runnable.run() should not throw an exception. Any uncaught exceptions should be logged by the worker pool implementation.
        Specified by:
        execute in interface WorkerPool
        Parameters:
        task - the task to execute
      • shutdown

        public void shutdown​(int timeout)
                      throws InterruptedException
        Description copied from interface: WorkerPool
        Destroy the worker pool. The pool will immediately stop accepting new tasks. All previously submitted tasks will be executed. The method blocks until all tasks have completed execution, or the timeout occurs, or the current thread is interrupted, whichever happens first.
        Specified by:
        shutdown in interface WorkerPool
        Parameters:
        timeout - the timeout value in milliseconds
        Throws:
        InterruptedException - if the current thread was interrupted while waiting for pending tasks to finish execution