Class ContextPropagatingScheduledExecutorService

java.lang.Object

io.micronaut.context.propagation.instrument.execution.ContextPropagatingExecutorService

io.micronaut.context.propagation.instrument.execution.ContextPropagatingScheduledExecutorService

All Implemented Interfaces:

InstrumentedExecutor, InstrumentedExecutorService, InstrumentedScheduledExecutorService, RunnableInstrumenter, AutoCloseable, Executor, ExecutorService, ScheduledExecutorService

@Internal
public class ContextPropagatingScheduledExecutorService
extends ContextPropagatingExecutorService
implements InstrumentedScheduledExecutorService

Wraps ScheduledExecutorService to instrument it for propagating the PropagatedContext across threads.

Since:

4.9.0

Author:

Hauke Lange

Constructor Summary

Constructors

Constructor	Description
ContextPropagatingScheduledExecutorService(ScheduledExecutorService target)
ContextPropagatingScheduledExecutorService(ScheduledExecutorService target, @Nullable PropagatedContext propagatedContext)

Method Summary

Modifier and Type	Method	Description
ScheduledExecutorService	getTarget()	Implementors can override to specify the target ExecutorService.

Methods inherited from class ContextPropagatingExecutorService

instrument, instrument, isInstrumented, unwrap

Methods inherited from class Object

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

Methods inherited from interface ExecutorService

close

Methods inherited from interface InstrumentedExecutor

execute

Methods inherited from interface InstrumentedExecutorService

awaitTermination, instrument, invokeAll, invokeAll, invokeAny, invokeAny, isShutdown, isTerminated, shutdown, shutdownNow, submit, submit, submit

Methods inherited from interface InstrumentedScheduledExecutorService

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from interface RunnableInstrumenter

instrument

Constructor Details

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target)

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target,
 @Nullable PropagatedContext propagatedContext)

Method Details

getTarget

public ScheduledExecutorService getTarget()

Description copied from interface: InstrumentedExecutorService

Implementors can override to specify the target ExecutorService.

Specified by:

getTarget in interface InstrumentedExecutor

Specified by:

getTarget in interface InstrumentedExecutorService

Specified by:

getTarget in interface InstrumentedScheduledExecutorService

Overrides:

getTarget in class ContextPropagatingExecutorService

Returns:

The target ExecutorService