public class TracedThreadPoolTaskExecutor
extends org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
| Constructor and Description |
|---|
TracedThreadPoolTaskExecutor(io.opentracing.Tracer tracer,
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor delegate) |
| Modifier and Type | Method and Description |
|---|---|
void |
afterPropertiesSet() |
void |
destroy() |
void |
execute(Runnable task) |
void |
execute(Runnable task,
long startTimeout) |
ThreadPoolExecutor |
getThreadPoolExecutor() |
void |
shutdown() |
<T> Future<T> |
submit(Callable<T> task) |
Future<?> |
submit(Runnable task) |
<T> org.springframework.util.concurrent.ListenableFuture<T> |
submitListenable(Callable<T> task) |
org.springframework.util.concurrent.ListenableFuture<?> |
submitListenable(Runnable task) |
cancelRemainingTask, createQueue, getActiveCount, getCorePoolSize, getKeepAliveSeconds, getMaxPoolSize, getPoolSize, initializeExecutor, prefersShortLivedTasks, setAllowCoreThreadTimeOut, setCorePoolSize, setKeepAliveSeconds, setMaxPoolSize, setQueueCapacity, setTaskDecoratorinitialize, setAwaitTerminationSeconds, setBeanName, setRejectedExecutionHandler, setThreadFactory, setThreadNamePrefix, setWaitForTasksToCompleteOnShutdownnewThreadpublic TracedThreadPoolTaskExecutor(io.opentracing.Tracer tracer,
org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor delegate)
public void execute(Runnable task)
public void execute(Runnable task, long startTimeout)
execute in interface org.springframework.core.task.AsyncTaskExecutorexecute in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorpublic Future<?> submit(Runnable task)
submit in interface org.springframework.core.task.AsyncTaskExecutorsubmit in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorpublic <T> Future<T> submit(Callable<T> task)
submit in interface org.springframework.core.task.AsyncTaskExecutorsubmit in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorpublic org.springframework.util.concurrent.ListenableFuture<?> submitListenable(Runnable task)
submitListenable in interface org.springframework.core.task.AsyncListenableTaskExecutorsubmitListenable in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorpublic <T> org.springframework.util.concurrent.ListenableFuture<T> submitListenable(Callable<T> task)
submitListenable in interface org.springframework.core.task.AsyncListenableTaskExecutorsubmitListenable in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorpublic void afterPropertiesSet()
afterPropertiesSet in interface org.springframework.beans.factory.InitializingBeanafterPropertiesSet in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupportpublic void destroy()
destroy in interface org.springframework.beans.factory.DisposableBeandestroy in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupportpublic void shutdown()
shutdown in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupportpublic ThreadPoolExecutor getThreadPoolExecutor() throws IllegalStateException
getThreadPoolExecutor in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutorIllegalStateExceptionCopyright © 2017–2018. All rights reserved.