org.geotools.process

Class ThreadPoolProcessExecutor

Object

AbstractExecutorService

ThreadPoolExecutor

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

Constructors

Constructor and Description
ThreadPoolProcessExecutor(int nThreads, ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and 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 ExecutorService

awaitTermination, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Methods inherited from interface Executor

execute

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

Parameters:

task - the task to submit

Returns:

a Progress representing pending completion of the task