com.netflix.concurrency.limits.limiter

Class LifoBlockingLimiter<ContextT>

java.lang.Object

com.netflix.concurrency.limits.limiter.LifoBlockingLimiter<ContextT>

Type Parameters:

ContextT -

All Implemented Interfaces:

Limiter<ContextT>

public final class LifoBlockingLimiter<ContextT>
extends java.lang.Object
implements Limiter<ContextT>

Limiter decorator that blocks the caller when the limit has been reached. This strategy ensures the resource is properly protected but favors availability over latency by not fast failing requests when the limit has been reached. To help keep success latencies low and minimize timeouts any blocked requests are processed in last in/first out order. Use this limiter only when the threading model allows the limiter to be blocked.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LifoBlockingLimiter.Builder<ContextT>

Nested classes/interfaces inherited from interface com.netflix.concurrency.limits.Limiter

Limiter.Listener

Method Summary

Modifier and Type	Method and Description
java.util.Optional<Limiter.Listener>	acquire(ContextT context) Acquire a token from the limiter.
static <ContextT> LifoBlockingLimiter.Builder<ContextT>	newBuilder(Limiter<ContextT> delegate)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

newBuilder

public static <ContextT> LifoBlockingLimiter.Builder<ContextT> newBuilder(Limiter<ContextT> delegate)

acquire

public java.util.Optional<Limiter.Listener> acquire(ContextT context)

Description copied from interface: Limiter

Acquire a token from the limiter. Returns an Optional.empty() if the limit has been exceeded. If acquired the caller must call one of the Listener methods when the operation has been completed to release the count.

Specified by:

acquire in interface Limiter<ContextT>

Parameters:

context - Context for the request

Returns:

Optional.empty() if limit exceeded.

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object