Class ThreadPoolProcessExecutor

  • All Implemented Interfaces:
    Executor, ExecutorService, ProcessExecutor

    public class ThreadPoolProcessExecutor
    extends ThreadPoolExecutor
    implements ProcessExecutor
    • Nested Class Summary

      • Nested classes/interfaces inherited from class ThreadPoolExecutor

        ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
    • Constructor Summary

      Constructor Description
      ThreadPoolProcessExecutor​(int nThreads, ThreadFactory threadFactory)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      Progress submit​(Process task, Map<String,​Object> input)
      Submits a process for execution and returns a Progress representing the pending results of the task.
      • Methods inherited from class ThreadPoolExecutor

        afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString
      • Methods inherited from class AbstractExecutorService

        invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
      • Methods inherited from class Object

        clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait
      • Methods inherited from interface Executor

      • Methods inherited from interface ExecutorService

        awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit
    • Constructor Detail

      • ThreadPoolProcessExecutor

        public ThreadPoolProcessExecutor​(int nThreads,
                                         ThreadFactory threadFactory)
    • Method Detail

      • submit

        public Progress submit​(Process task,
                               Map<String,​Object> input)
        Description copied from interface: ProcessExecutor
        Submits a process for execution and returns a Progress representing the pending results of the task.

        If you would like to immediately block waiting for a task, you can use constructions of the form result = exec.submit(aProcess).get();

        Note: The Processors class includes a set of methods that can convert some other common closure-like objects, for example, Callable to Process form so they can be submitted.

        Specified by:
        submit in interface ProcessExecutor
        task - the task to submit
        a Progress representing pending completion of the task