-
- All Implemented Interfaces:
-
java.util.concurrent.Executor
,java.util.concurrent.ExecutorService
public class AutomaticCancelableThreadExecutor extends ThreadPoolExecutor
-
-
Field Summary
Fields Modifier and Type Field Description private long
timeout
-
Constructor Summary
Constructors Constructor Description AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
-
Method Summary
Modifier and Type Method Description void
setTimeout(long timeout, TimeUnit timeUnit)
<T> Future<T>
submit(Callable<T> task, long customTimeout, TimeUnit cutomTimeUnit)
<T> Future<T>
submit(Callable<T> task)
<T> Future<T>
submit(Runnable task, T result)
Future<out Object>
submit(Runnable task)
-
Methods inherited from class java.util.concurrent.ThreadPoolExecutor
allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, 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, toString
-
Methods inherited from class java.util.concurrent.AbstractExecutorService
invokeAll, invokeAny, submit, submit
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
-
Constructor Detail
-
AutomaticCancelableThreadExecutor
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
-
AutomaticCancelableThreadExecutor
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
-
AutomaticCancelableThreadExecutor
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
-
AutomaticCancelableThreadExecutor
AutomaticCancelableThreadExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
-
-
Method Detail
-
setTimeout
void setTimeout(long timeout, TimeUnit timeUnit)
-
-
-
-