Package io.opentelemetry.javaagent.instrumentation.api.concurrent

Class ExecutorInstrumentationUtils

java.lang.Object

io.opentelemetry.javaagent.instrumentation.api.concurrent.ExecutorInstrumentationUtils

public final class ExecutorInstrumentationUtils
extends Object

Utils for concurrent instrumentations.

Method Summary

Modifier and Type	Method	Description
static void	cleanUpOnMethodExit(State state, Throwable throwable)	Clean up after job submission method has exited.
static <T> State	setupState(ContextStore<T,State> contextStore, T task, io.opentelemetry.context.Context context)	Create task state given current scope.
static boolean	shouldAttachStateToTask(Object task)	Checks if given task should get state attached.

Methods inherited from class java.lang.Object

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

Method Detail

shouldAttachStateToTask

public static boolean shouldAttachStateToTask(Object task)

Checks if given task should get state attached.

Parameters:

task - task object

Returns:

true iff given task object should be wrapped

setupState

public static <T> State setupState(ContextStore<T,State> contextStore,
                                   T task,
                                   io.opentelemetry.context.Context context)

Create task state given current scope.

Type Parameters:

T - task class type

Parameters:

contextStore - context storage

task - task instance

context - current context

Returns:

new state

cleanUpOnMethodExit

public static void cleanUpOnMethodExit(State state,
                                       Throwable throwable)

Clean up after job submission method has exited.

Parameters:

state - task instrumentation state

throwable - throwable that may have been thrown