public final class WorkContinuationInstrumenter
extends java.lang.Object
WorkContinuationInstrumenter.Instrumenter
that will receive ad-hoc updates when work that has to be executed across
threads gets moved around.Modifier and Type | Class and Description |
---|---|
static interface |
WorkContinuationInstrumenter.Instrumenter
Allows to record work being continued across threads.
|
Constructor and Description |
---|
WorkContinuationInstrumenter() |
Modifier and Type | Method and Description |
---|---|
static void |
markFailure(java.lang.Object token,
java.lang.Throwable th) |
static java.lang.Object |
onAskForWorkToContinue(java.lang.String tag) |
static java.lang.Object |
onBeginWorkContinuation(java.lang.String tag,
java.lang.Object token) |
static void |
onEndWorkContinuation(java.lang.Object token) |
static java.lang.Object |
onOfferWorkForContinuation(java.lang.String tag) |
static java.lang.Object |
onOfferWorkForContinuation(java.lang.String tag,
java.lang.Object token) |
static void |
provide(WorkContinuationInstrumenter.Instrumenter instrumenter)
Allows to provide an instrumenter that will receive work continuation updates.
|
public static void provide(WorkContinuationInstrumenter.Instrumenter instrumenter)
instrumenter
- that will receive the updates or null to reset.public static java.lang.Object onAskForWorkToContinue(java.lang.String tag)
public static java.lang.Object onOfferWorkForContinuation(java.lang.String tag)
public static java.lang.Object onOfferWorkForContinuation(java.lang.String tag, java.lang.Object token)
public static java.lang.Object onBeginWorkContinuation(java.lang.String tag, java.lang.Object token)
public static void onEndWorkContinuation(java.lang.Object token)
public static void markFailure(java.lang.Object token, java.lang.Throwable th)