com.netflix.concurrency.limits.executors

Class BlockingAdaptiveExecutor

java.lang.Object

com.netflix.concurrency.limits.executors.BlockingAdaptiveExecutor

All Implemented Interfaces:

java.util.concurrent.Executor

public final class BlockingAdaptiveExecutor
extends java.lang.Object
implements java.util.concurrent.Executor

Executor which uses a Limiter to determine the size of the thread pool. Any Runnable executed once the limit has been reached will block the calling thread until the limit is released. Operations submitted to this executor should be homogeneous and have similar long term latency characteristics. RTT samples will only be taken from successful operations. The Runnable should throw a UncheckedTimeoutException if a request timed out or some external limit was reached. All other exceptions will be ignored.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	BlockingAdaptiveExecutor.Builder

Constructor Summary

Constructors

Constructor and Description
BlockingAdaptiveExecutor(Limiter<java.lang.Void> limiter) Deprecated.
BlockingAdaptiveExecutor(Limiter<java.lang.Void> limiter, java.util.concurrent.Executor executor) Deprecated.

Method Summary

Modifier and Type	Method and Description
void	execute(java.lang.Runnable command)
static BlockingAdaptiveExecutor.Builder	newBuilder()

Methods inherited from class java.lang.Object

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

Constructor Detail

BlockingAdaptiveExecutor

@Deprecated
public BlockingAdaptiveExecutor(Limiter<java.lang.Void> limiter)

Deprecated.

BlockingAdaptiveExecutor

@Deprecated
public BlockingAdaptiveExecutor(Limiter<java.lang.Void> limiter,
                                            java.util.concurrent.Executor executor)

Deprecated.

Method Detail

newBuilder

public static BlockingAdaptiveExecutor.Builder newBuilder()

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor