Package 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 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 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
toProcess
form so they can be submitted.- Specified by:
submit
in interfaceProcessExecutor
- Parameters:
task
- the task to submit- Returns:
- a Progress representing pending completion of the task
-
-