Module org.elasticsearch.server

Package org.elasticsearch.common.util.concurrent

Class ThrottledTaskRunner

java.lang.Object

org.elasticsearch.common.util.concurrent.AbstractThrottledTaskRunner<ActionListener<Releasable>>

org.elasticsearch.common.util.concurrent.ThrottledTaskRunner

public class ThrottledTaskRunner
extends AbstractThrottledTaskRunner<ActionListener<Releasable>>

Constructor Summary

Constructors

Constructor	Description
ThrottledTaskRunner(String name, int maxRunningTasks, Executor executor)

Method Summary

Modifier and Type	Method	Description
Executor	asExecutor()	Returns a new Executor implementation that delegates tasks to this ThrottledTaskRunner.

Methods inherited from class org.elasticsearch.common.util.concurrent.AbstractThrottledTaskRunner

enqueueTask, getTaskRunnerName, isForceExecution, runSyncTasksEagerly

Methods inherited from class java.lang.Object

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

Constructor Details

ThrottledTaskRunner

public ThrottledTaskRunner(String name,
 int maxRunningTasks,
 Executor executor)

Method Details

asExecutor

public Executor asExecutor()

Returns a new Executor implementation that delegates tasks to this ThrottledTaskRunner.
NOTE: The Runnables to be executed via Executor.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 this ThrottledTaskRunner. If more control is needed for when a task is done for throttling purposes, see AbstractThrottledTaskRunner.enqueueTask(ActionListener).