Package com.netflix.hystrix

Class HystrixThreadPool.HystrixThreadPoolDefault

java.lang.Object

com.netflix.hystrix.HystrixThreadPool.HystrixThreadPoolDefault

All Implemented Interfaces:

HystrixThreadPool

Enclosing interface:

HystrixThreadPool

public static class HystrixThreadPool.HystrixThreadPoolDefault
extends java.lang.Object
implements HystrixThreadPool

Nested Class Summary

Nested classes/interfaces inherited from interface com.netflix.hystrix.HystrixThreadPool

HystrixThreadPool.Factory, HystrixThreadPool.HystrixThreadPoolDefault

Constructor Summary

Constructors

Constructor and Description
HystrixThreadPoolDefault(HystrixThreadPoolKey threadPoolKey, HystrixThreadPoolProperties.Setter propertiesDefaults)

Method Summary

Modifier and Type	Method and Description
java.util.concurrent.ThreadPoolExecutor	getExecutor() Implementation of ThreadPoolExecutor.
rx.Scheduler	getScheduler()
rx.Scheduler	getScheduler(rx.functions.Func0<java.lang.Boolean> shouldInterruptThread)
boolean	isQueueSpaceAvailable() Whether the threadpool queue has space available according to the queueSizeRejectionThreshold settings.
void	markThreadCompletion() Mark when a thread completes executing a command.
void	markThreadExecution() Mark when a thread begins executing a command.
void	markThreadRejection() Mark when a command gets rejected from the threadpool

Methods inherited from class java.lang.Object

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

Constructor Detail

HystrixThreadPoolDefault

public HystrixThreadPoolDefault(HystrixThreadPoolKey threadPoolKey,
                                HystrixThreadPoolProperties.Setter propertiesDefaults)

Method Detail

getExecutor

public java.util.concurrent.ThreadPoolExecutor getExecutor()

Description copied from interface: HystrixThreadPool

Implementation of ThreadPoolExecutor.

Specified by:

getExecutor in interface HystrixThreadPool

Returns:

ThreadPoolExecutor

getScheduler

public rx.Scheduler getScheduler()

Specified by:

getScheduler in interface HystrixThreadPool

getScheduler

public rx.Scheduler getScheduler(rx.functions.Func0<java.lang.Boolean> shouldInterruptThread)

Specified by:

getScheduler in interface HystrixThreadPool

markThreadExecution

public void markThreadExecution()

Description copied from interface: HystrixThreadPool

Mark when a thread begins executing a command.

Specified by:

markThreadExecution in interface HystrixThreadPool

markThreadCompletion

public void markThreadCompletion()

Description copied from interface: HystrixThreadPool

Mark when a thread completes executing a command.

Specified by:

markThreadCompletion in interface HystrixThreadPool

markThreadRejection

public void markThreadRejection()

Description copied from interface: HystrixThreadPool

Mark when a command gets rejected from the threadpool

Specified by:

markThreadRejection in interface HystrixThreadPool

isQueueSpaceAvailable

public boolean isQueueSpaceAvailable()

Whether the threadpool queue has space available according to the queueSizeRejectionThreshold settings. Note that the queueSize is an final instance variable on HystrixThreadPoolDefault, and not looked up dynamically. The data structure is static, so this does not make sense as a dynamic lookup. The queueSizeRejectionThreshold can be dynamic (up to queueSize), so that should still get checked on each invocation.

If a SynchronousQueue implementation is used (maxQueueSize <= 0), it always returns 0 as the size so this would always return true.

Specified by:

isQueueSpaceAvailable in interface HystrixThreadPool

Returns:

boolean whether there is space on the queue