Module org.elasticsearch.server
Package org.elasticsearch.action.support
Class RefCountAwareThreadedActionListener<Response extends RefCounted>
java.lang.Object
org.elasticsearch.action.support.AbstractThreadedActionListener<Response>
org.elasticsearch.action.support.RefCountAwareThreadedActionListener<Response>
- All Implemented Interfaces:
ActionListener<Response>
public final class RefCountAwareThreadedActionListener<Response extends RefCounted>
extends AbstractThreadedActionListener<Response>
Same as
ThreadedActionListener but for RefCounted types. Makes sure to increment ref-count by one before forking
to another thread and decrementing after the forked task completes.-
Field Summary
Fields inherited from class org.elasticsearch.action.support.AbstractThreadedActionListener
delegate, executor, forceExecution -
Constructor Summary
ConstructorsConstructorDescriptionRefCountAwareThreadedActionListener(Executor executor, ActionListener<Response> delegate) -
Method Summary
Modifier and TypeMethodDescriptionvoidonResponse(Response response) Complete this listener with a successful (or at least, non-exceptional) response.Methods inherited from class org.elasticsearch.action.support.AbstractThreadedActionListener
onFailure, toStringMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.elasticsearch.action.ActionListener
delegateFailure, delegateFailureAndWrap, delegateFailureIgnoreResponseAndWrap, delegateResponse, map, safeMap
-
Constructor Details
-
RefCountAwareThreadedActionListener
-
-
Method Details
-
onResponse
Description copied from interface:ActionListenerComplete this listener with a successful (or at least, non-exceptional) response.
-