Module org.elasticsearch.server
Class ThrottledTaskRunner
java.lang.Object
org.elasticsearch.common.util.concurrent.AbstractThrottledTaskRunner<ActionListener<Releasable>>
org.elasticsearch.common.util.concurrent.ThrottledTaskRunner
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionReturns a newExecutorimplementation that delegates tasks to thisThrottledTaskRunner.Methods inherited from class org.elasticsearch.common.util.concurrent.AbstractThrottledTaskRunner
enqueueTask, getTaskRunnerName, isForceExecution, runSyncTasksEagerly
-
Constructor Details
-
ThrottledTaskRunner
-
-
Method Details
-
asExecutor
Returns a newExecutorimplementation that delegates tasks to thisThrottledTaskRunner.
NOTE: TheRunnables to be executed viaExecutor.execute(Runnable)are throttled to the extent that they do NOT fork off on a different executor. If they do, the part that's forked off is not throttled by thisThrottledTaskRunner. If more control is needed for when a task is done for throttling purposes, seeAbstractThrottledTaskRunner.enqueueTask(ActionListener).
-