top.dcenter.ums.security.common.executor

类 MdcThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

top.dcenter.ums.security.common.executor.MdcThreadPoolExecutor

所有已实现的接口:

Executor, ExecutorService

public class MdcThreadPoolExecutor
extends ThreadPoolExecutor

实现 基于 SLF4J MDC 机制的日志链路追踪功能.
ThreadPoolExecutor.remove(Runnable) 类内部调用有效, 通过实例调用此方法失效

版本:

V2.0 Created by 2020-12-22 10:52

作者:

YongWu zheng

嵌套类概要

从类继承的嵌套类/接口 java.util.concurrent.ThreadPoolExecutor

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

构造器概要

构造器

构造器和说明
MdcThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue)
MdcThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, RejectedExecutionHandler handler)
MdcThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory)
MdcThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)

方法概要

限定符和类型	方法和说明
void	execute(Runnable runnable)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks)
<T> List<Future<T>>	invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks)
<T> T	invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)
<T> Future<T>	submit(Callable<T> task)
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)

从类继承的方法 java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, 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

从类继承的方法 java.util.concurrent.AbstractExecutorService

newTaskFor, newTaskFor

从类继承的方法 java.lang.Object

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

构造器详细资料

MdcThreadPoolExecutor

public MdcThreadPoolExecutor(int corePoolSize,
                             int maximumPoolSize,
                             long keepAliveTime,
                             TimeUnit unit,
                             BlockingQueue<Runnable> workQueue)

MdcThreadPoolExecutor

public MdcThreadPoolExecutor(int corePoolSize,
                             int maximumPoolSize,
                             long keepAliveTime,
                             TimeUnit unit,
                             BlockingQueue<Runnable> workQueue,
                             ThreadFactory threadFactory)

MdcThreadPoolExecutor

public MdcThreadPoolExecutor(int corePoolSize,
                             int maximumPoolSize,
                             long keepAliveTime,
                             TimeUnit unit,
                             BlockingQueue<Runnable> workQueue,
                             RejectedExecutionHandler handler)

MdcThreadPoolExecutor

public MdcThreadPoolExecutor(int corePoolSize,
                             int maximumPoolSize,
                             long keepAliveTime,
                             TimeUnit unit,
                             BlockingQueue<Runnable> workQueue,
                             ThreadFactory threadFactory,
                             RejectedExecutionHandler handler)

方法详细资料

execute

public void execute(@NonNull
                    Runnable runnable)

指定者:

execute 在接口中 Executor

覆盖:

execute 在类中 ThreadPoolExecutor

submit

@NonNull
public Future<?> submit(@NonNull
                                  Runnable task)

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

submit

@NonNull
public <T> Future<T> submit(@NonNull
                                      Callable<T> task)

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

submit

@NonNull
public <T> Future<T> submit(Runnable task,
                                      T result)

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 AbstractExecutorService

invokeAny

@NonNull
public <T> T invokeAny(Collection<? extends Callable<T>> tasks)
                          throws InterruptedException,
                                 ExecutionException

指定者:

invokeAny 在接口中 ExecutorService

覆盖:

invokeAny 在类中 AbstractExecutorService

抛出:

InterruptedException

ExecutionException

invokeAny

public <T> T invokeAny(Collection<? extends Callable<T>> tasks,
                       long timeout,
                       TimeUnit unit)
                throws InterruptedException,
                       ExecutionException,
                       TimeoutException

指定者:

invokeAny 在接口中 ExecutorService

覆盖:

invokeAny 在类中 AbstractExecutorService

抛出:

InterruptedException

ExecutionException

TimeoutException

invokeAll

@NonNull
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
                                        throws InterruptedException

指定者:

invokeAll 在接口中 ExecutorService

覆盖:

invokeAll 在类中 AbstractExecutorService

抛出:

InterruptedException

invokeAll

@NonNull
public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
                                               long timeout,
                                               TimeUnit unit)
                                        throws InterruptedException

指定者:

invokeAll 在接口中 ExecutorService

覆盖:

invokeAll 在类中 AbstractExecutorService

抛出:

InterruptedException