ThrottledTaskPool

Constructors

this

this()

Constructor

this

this(ISuspendableThrottler throttler)

Constructor

this

this(size_t suspend_point, size_t resume_point)

Constructor

Members

Functions

registerThrottlingHook

void registerThrottlingHook()

Registers throttling hook if not already present

startImpl

void startImpl(Task task)

Register throttling hook and check for suspend when starting a task.

useThrottler

void useThrottler(ISuspendableThrottler throttler)

Sets or replaces current throttler instance

Variables

throttler

ISuspendableThrottler throttler;

Throttler used to control tempo of data consumption from streams. By default internally defined PoolThrottler is used which is bound by task pool size limit.

• PoolThrottler
• SpecializedPoolThrottler
• ThrottledTaskPool