public class ExecutorWithListener extends ThreadPoolExecutor
限定符和类型 | 类和说明 |
---|---|
static interface |
ExecutorWithListener.OnAllTaskEndListener |
static interface |
ExecutorWithListener.OnTaskEndListener |
ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy
构造器和说明 |
---|
ExecutorWithListener(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue) |
ExecutorWithListener(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler) |
ExecutorWithListener(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory) |
ExecutorWithListener(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) |
限定符和类型 | 方法和说明 |
---|---|
void |
addOnAllTaskEndListener(ExecutorWithListener.OnAllTaskEndListener allTaskEndListener) |
void |
addOnTaskEndListener(ExecutorWithListener.OnTaskEndListener taskEndListener) |
protected void |
afterExecute(Runnable r,
Throwable t)
任务结束后回调
|
void |
removeOnAllTaskEndListener(ExecutorWithListener.OnAllTaskEndListener allTaskEndListener) |
void |
removeOnTaskEndListener(ExecutorWithListener.OnTaskEndListener taskEndListener) |
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
invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit
public ExecutorWithListener(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
public ExecutorWithListener(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)
public ExecutorWithListener(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
public ExecutorWithListener(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
protected void afterExecute(Runnable r, Throwable t)
afterExecute
在类中 ThreadPoolExecutor
public void addOnTaskEndListener(ExecutorWithListener.OnTaskEndListener taskEndListener)
public void removeOnTaskEndListener(ExecutorWithListener.OnTaskEndListener taskEndListener)
public void addOnAllTaskEndListener(ExecutorWithListener.OnAllTaskEndListener allTaskEndListener)
public void removeOnAllTaskEndListener(ExecutorWithListener.OnAllTaskEndListener allTaskEndListener)