top.dcenter.ums.security.common.executor

类 MdcScheduledThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ScheduledThreadPoolExecutor

top.dcenter.ums.security.common.executor.MdcScheduledThreadPoolExecutor

所有已实现的接口:

Executor, ExecutorService, ScheduledExecutorService

public class MdcScheduledThreadPoolExecutor
extends ScheduledThreadPoolExecutor

实现 基于 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

构造器概要

构造器

构造器和说明
MdcScheduledThreadPoolExecutor(int corePoolSize)
MdcScheduledThreadPoolExecutor(int corePoolSize, RejectedExecutionHandler handler)
MdcScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory)
MdcScheduledThreadPoolExecutor(int corePoolSize, ThreadFactory threadFactory, RejectedExecutionHandler handler)

方法概要

限定符和类型	方法和说明
void	execute(Runnable command)
<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)
<V> ScheduledFuture<V>	schedule(Callable<V> callable, long delay, TimeUnit unit)
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit)
ScheduledFuture<?>	scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)
ScheduledFuture<?>	scheduleWithFixedDelay(Runnable command, long initialDelay, long delay, TimeUnit unit)
<T> Future<T>	submit(Callable<T> task)
Future<?>	submit(Runnable task)
<T> Future<T>	submit(Runnable task, T result)

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

decorateTask, decorateTask, getContinueExistingPeriodicTasksAfterShutdownPolicy, getExecuteExistingDelayedTasksAfterShutdownPolicy, getQueue, getRemoveOnCancelPolicy, setContinueExistingPeriodicTasksAfterShutdownPolicy, setExecuteExistingDelayedTasksAfterShutdownPolicy, setRemoveOnCancelPolicy, shutdown, shutdownNow

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

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, terminated, toString

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

newTaskFor, newTaskFor

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

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

从接口继承的方法 java.util.concurrent.ExecutorService

awaitTermination, isShutdown, isTerminated

构造器详细资料

MdcScheduledThreadPoolExecutor

public MdcScheduledThreadPoolExecutor(int corePoolSize)

MdcScheduledThreadPoolExecutor

public MdcScheduledThreadPoolExecutor(int corePoolSize,
                                      ThreadFactory threadFactory)

MdcScheduledThreadPoolExecutor

public MdcScheduledThreadPoolExecutor(int corePoolSize,
                                      RejectedExecutionHandler handler)

MdcScheduledThreadPoolExecutor

public MdcScheduledThreadPoolExecutor(int corePoolSize,
                                      ThreadFactory threadFactory,
                                      RejectedExecutionHandler handler)

方法详细资料

schedule

@NonNull
public ScheduledFuture<?> schedule(Runnable command,
                                             long delay,
                                             TimeUnit unit)

指定者:

schedule 在接口中 ScheduledExecutorService

覆盖:

schedule 在类中 ScheduledThreadPoolExecutor

schedule

@NonNull
public <V> ScheduledFuture<V> schedule(Callable<V> callable,
                                                 long delay,
                                                 TimeUnit unit)

指定者:

schedule 在接口中 ScheduledExecutorService

覆盖:

schedule 在类中 ScheduledThreadPoolExecutor

scheduleAtFixedRate

@NonNull
public ScheduledFuture<?> scheduleAtFixedRate(Runnable command,
                                                        long initialDelay,
                                                        long period,
                                                        TimeUnit unit)

指定者:

scheduleAtFixedRate 在接口中 ScheduledExecutorService

覆盖:

scheduleAtFixedRate 在类中 ScheduledThreadPoolExecutor

scheduleWithFixedDelay

@NonNull
public ScheduledFuture<?> scheduleWithFixedDelay(Runnable command,
                                                           long initialDelay,
                                                           long delay,
                                                           TimeUnit unit)

指定者:

scheduleWithFixedDelay 在接口中 ScheduledExecutorService

覆盖:

scheduleWithFixedDelay 在类中 ScheduledThreadPoolExecutor

execute

public void execute(Runnable command)

指定者:

execute 在接口中 Executor

覆盖:

execute 在类中 ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 ScheduledThreadPoolExecutor

submit

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

指定者:

submit 在接口中 ExecutorService

覆盖:

submit 在类中 ScheduledThreadPoolExecutor

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