public static interface WorkContinuationInstrumenter.Instrumenter
Modifier and Type | Method and Description |
---|---|
boolean |
isTracing()
Allows to know in advance if the custom instrumenter desires to receive continuation updates.
|
void |
markFailure(java.lang.Object token,
java.lang.Throwable th)
Reports a failure while executing work.
|
java.lang.Object |
onAskForWorkToContinue(java.lang.String tag)
Captures when asking for work to be stolen.
|
java.lang.Object |
onBeginWorkContinuation(java.lang.String tag,
java.lang.Object token)
Captures the beginning of the continuation for stolen work.
|
void |
onEndWorkContinuation(java.lang.Object token)
Captures the end of the continuation for stolen work.
|
java.lang.Object |
onOfferWorkForContinuation(java.lang.String tag)
Tracks when some work is ready to offered for continuation.
|
java.lang.Object |
onOfferWorkForContinuation(java.lang.String tag,
java.lang.Object token)
Tracks when some work is ready to be stolen.
|
boolean isTracing()
java.lang.Object onAskForWorkToContinue(java.lang.String tag)
tag
- name.java.lang.Object onOfferWorkForContinuation(java.lang.String tag)
tag
- name.java.lang.Object onOfferWorkForContinuation(java.lang.String tag, java.lang.Object token)
tag
- name (optional).token
- returned by onAskForWorkToContinue(java.lang.String)
.java.lang.Object onBeginWorkContinuation(java.lang.String tag, java.lang.Object token)
tag
- name (optional).token
- returned by onOfferWorkForContinuation(java.lang.String)
.void onEndWorkContinuation(java.lang.Object token)
token
- returned by onBeginWorkContinuation(java.lang.String, java.lang.Object)
.void markFailure(java.lang.Object token, java.lang.Throwable th)
onEndWorkContinuation(Object)
(Object)} still needs to be
invoked.
token
- returned by onBeginWorkContinuation(String, Object)
(Object, String)}.th
- containing the failure.