io.opentracing.contrib.spring.cloud.async.instrument

Class TracedThreadPoolTaskExecutor

java.lang.Object

org.springframework.util.CustomizableThreadCreator

org.springframework.scheduling.concurrent.CustomizableThreadFactory

org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

io.opentracing.contrib.spring.cloud.async.instrument.TracedThreadPoolTaskExecutor

All Implemented Interfaces:

Serializable, Executor, ThreadFactory, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.core.task.AsyncListenableTaskExecutor, org.springframework.core.task.AsyncTaskExecutor, org.springframework.core.task.TaskExecutor, org.springframework.scheduling.SchedulingTaskExecutor

public class TracedThreadPoolTaskExecutor
extends org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

Author:

kameshsampath

See Also:

Serialized Form

Field Summary

Fields inherited from class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

logger

Fields inherited from interface org.springframework.core.task.AsyncTaskExecutor

TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

Constructor Summary

Constructors

Constructor and Description
TracedThreadPoolTaskExecutor(io.opentracing.Tracer tracer, org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor delegate)

Method Summary

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)

Methods inherited from class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

cancelRemainingTask, createQueue, getActiveCount, getCorePoolSize, getKeepAliveSeconds, getMaxPoolSize, getPoolSize, initializeExecutor, prefersShortLivedTasks, setAllowCoreThreadTimeOut, setCorePoolSize, setKeepAliveSeconds, setMaxPoolSize, setQueueCapacity, setTaskDecorator

Methods inherited from class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

initialize, setAwaitTerminationSeconds, setBeanName, setRejectedExecutionHandler, setThreadFactory, setThreadNamePrefix, setWaitForTasksToCompleteOnShutdown

Methods inherited from class org.springframework.scheduling.concurrent.CustomizableThreadFactory

newThread

Methods inherited from class org.springframework.util.CustomizableThreadCreator

createThread, getDefaultThreadNamePrefix, getThreadGroup, getThreadNamePrefix, getThreadPriority, isDaemon, nextThreadName, setDaemon, setThreadGroup, setThreadGroupName, setThreadPriority

Methods inherited from class java.lang.Object

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

Constructor Detail

TracedThreadPoolTaskExecutor

public TracedThreadPoolTaskExecutor(io.opentracing.Tracer tracer,
                                    org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor delegate)

Method Detail

execute

public void execute(Runnable task)

Specified by:

execute in interface Executor

Specified by:

execute in interface org.springframework.core.task.TaskExecutor

Overrides:

execute in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

execute

public void execute(Runnable task,
                    long startTimeout)

Specified by:

execute in interface org.springframework.core.task.AsyncTaskExecutor

Overrides:

execute in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

submit

public Future<?> submit(Runnable task)

Specified by:

submit in interface org.springframework.core.task.AsyncTaskExecutor

Overrides:

submit in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

submit

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

Specified by:

submit in interface org.springframework.core.task.AsyncTaskExecutor

Overrides:

submit in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

submitListenable

public org.springframework.util.concurrent.ListenableFuture<?> submitListenable(Runnable task)

Specified by:

submitListenable in interface org.springframework.core.task.AsyncListenableTaskExecutor

Overrides:

submitListenable in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

submitListenable

public <T> org.springframework.util.concurrent.ListenableFuture<T> submitListenable(Callable<T> task)

Specified by:

submitListenable in interface org.springframework.core.task.AsyncListenableTaskExecutor

Overrides:

submitListenable in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

Overrides:

afterPropertiesSet in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

destroy

public void destroy()

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

Overrides:

destroy in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

shutdown

public void shutdown()

Overrides:

shutdown in class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

getThreadPoolExecutor

public ThreadPoolExecutor getThreadPoolExecutor()
                                         throws IllegalStateException

Overrides:

getThreadPoolExecutor in class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor

Throws:

IllegalStateException