org.geotools.process
Class ThreadPoolProcessExecutor

Object
  extended by AbstractExecutorService
      extended by ThreadPoolExecutor
          extended by 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
ThreadPoolProcessExecutor(int nThreads, ThreadFactory threadFactory)
           
 
Method Summary
 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
 
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, toString, 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


Copyright © 1996-2014 Geotools. All Rights Reserved.