com.barchart.util.concurrent
Class FutureCallbackExecutor

java.lang.Object
  java.util.concurrent.AbstractExecutorService
      java.util.concurrent.ThreadPoolExecutor
          com.barchart.util.concurrent.FutureCallbackExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class FutureCallbackExecutor
extends ThreadPoolExecutor

Executes tasks in a thread pool. submit() method return a FutureCallback instance, to allow easily attaching notification callbacks to jobs.

Author:

jeremy

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

FutureCallbackExecutor(int poolSize, int maxPoolSize, long keepAlive, TimeUnit units, BlockingQueue<Runnable> queue)

Method Summary

protected <T> FutureCallbackTask<T>	newTaskFor(Callable<T> callable)
protected <T> FutureCallbackTask<T>	newTaskFor(Runnable runnable, T value)
<T> FutureCallbackTask<T>	submit(Callable<T> callable)
FutureCallbackTask<?>	submit(Runnable runnable)
<T> FutureCallbackTask<T>	submit(Runnable runnable, T value)

Methods inherited from class java.util.concurrent.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 java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny

Methods inherited from class java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

FutureCallbackExecutor

public FutureCallbackExecutor(int poolSize,
                              int maxPoolSize,
                              long keepAlive,
                              TimeUnit units,
                              BlockingQueue<Runnable> queue)

Method Detail

newTaskFor

protected <T> FutureCallbackTask<T> newTaskFor(Callable<T> callable)

Overrides:

newTaskFor in class AbstractExecutorService

newTaskFor

protected <T> FutureCallbackTask<T> newTaskFor(Runnable runnable,
                                               T value)

Overrides:

newTaskFor in class AbstractExecutorService

submit

public <T> FutureCallbackTask<T> submit(Callable<T> callable)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public <T> FutureCallbackTask<T> submit(Runnable runnable,
                                        T value)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService

submit

public FutureCallbackTask<?> submit(Runnable runnable)

Specified by:

submit in interface ExecutorService

Overrides:

submit in class AbstractExecutorService