Class ThreadPoolProcessExecutor

All Implemented Interfaces:
Executor, ExecutorService, ProcessExecutor

public class ThreadPoolProcessExecutor extends ThreadPoolExecutor implements ProcessExecutor
  • Constructor Details

    • ThreadPoolProcessExecutor

      public ThreadPoolProcessExecutor(int nThreads, ThreadFactory threadFactory)
  • Method Details

    • 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
      Parameters:
      task - the task to submit
      Returns:
      a Progress representing pending completion of the task