Package io.micronaut.context.propagation.instrument.execution

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, 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 io.micronaut.context.propagation.instrument.execution.ContextPropagatingExecutorService

instrument, instrument, isInstrumented, unwrap

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedExecutor

execute

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedExecutorService

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

Methods inherited from interface io.micronaut.scheduling.instrument.InstrumentedScheduledExecutorService

schedule, schedule, scheduleAtFixedRate, scheduleWithFixedDelay

Methods inherited from interface io.micronaut.scheduling.instrument.RunnableInstrumenter

instrument

Constructor Details

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target)

ContextPropagatingScheduledExecutorService

public ContextPropagatingScheduledExecutorService(ScheduledExecutorService target,
 @Nullable
 @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