com.netflix.concurrency.limits.limiter

Class LifoBlockingLimiter.Builder<ContextT>

java.lang.Object

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

Enclosing class:

LifoBlockingLimiter<ContextT>

public static class LifoBlockingLimiter.Builder<ContextT>
extends java.lang.Object

Method Summary

Modifier and Type	Method and Description
LifoBlockingLimiter.Builder<ContextT>	backlogSize(int size) Set maximum number of blocked threads
LifoBlockingLimiter.Builder<ContextT>	backlogTimeout(java.util.function.Function<ContextT,java.lang.Long> mapper, java.util.concurrent.TimeUnit units) Function to derive the backlog timeout from the request context.
LifoBlockingLimiter.Builder<ContextT>	backlogTimeout(long timeout, java.util.concurrent.TimeUnit units) Set maximum timeout for threads blocked on the limiter.
LifoBlockingLimiter.Builder<ContextT>	backlogTimeoutMillis(long timeout) Set maximum timeout for threads blocked on the limiter.
LifoBlockingLimiter<ContextT>	build()
LifoBlockingLimiter.Builder<ContextT>	maxBacklogSize(int size) Deprecated. Use backlogSize(int)

Methods inherited from class java.lang.Object

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

Method Detail

backlogSize

public LifoBlockingLimiter.Builder<ContextT> backlogSize(int size)

Set maximum number of blocked threads

Parameters:

size - New max size. Default is 100.

Returns:

Chainable builder

maxBacklogSize

@Deprecated
public LifoBlockingLimiter.Builder<ContextT> maxBacklogSize(int size)

Deprecated. Use backlogSize(int)

backlogTimeout

public LifoBlockingLimiter.Builder<ContextT> backlogTimeout(long timeout,
                                                            java.util.concurrent.TimeUnit units)

Set maximum timeout for threads blocked on the limiter. Default is 1 second.

Parameters:

timeout -

units -

Returns:

Chainable builder

backlogTimeoutMillis

public LifoBlockingLimiter.Builder<ContextT> backlogTimeoutMillis(long timeout)

Set maximum timeout for threads blocked on the limiter. Default is 1 second.

Parameters:

timeout -

Returns:

Chainable builder

backlogTimeout

public LifoBlockingLimiter.Builder<ContextT> backlogTimeout(java.util.function.Function<ContextT,java.lang.Long> mapper,
                                                            java.util.concurrent.TimeUnit units)

Function to derive the backlog timeout from the request context. This allows timeouts to be set dynamically based on things like request deadlines.

Parameters:

mapper -

units -

Returns:

build

public LifoBlockingLimiter<ContextT> build()