Class HystrixTaskScheduler

Namespace

Steeltoe.CircuitBreaker.Hystrix.Strategy.Concurrency

Assembly

Steeltoe.CircuitBreaker.HystrixBase.dll

public abstract class HystrixTaskScheduler : TaskScheduler, IHystrixTaskScheduler, IDisposable

Inheritance

object

TaskScheduler

HystrixTaskScheduler

Implements

IHystrixTaskScheduler

IDisposable

Derived

HystrixQueuedTaskScheduler

HystrixSyncTaskScheduler

Inherited Members

TaskScheduler.FromCurrentSynchronizationContext()

TaskScheduler.GetScheduledTasks()

TaskScheduler.QueueTask(Task)

TaskScheduler.TryDequeue(Task)

TaskScheduler.TryExecuteTask(Task)

TaskScheduler.TryExecuteTaskInline(Task, bool)

TaskScheduler.Current

TaskScheduler.Default

TaskScheduler.Id

TaskScheduler.UnobservedTaskException

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Constructors

HystrixTaskScheduler(IHystrixThreadPoolOptions)

public HystrixTaskScheduler(IHystrixThreadPoolOptions options)

Parameters

options IHystrixThreadPoolOptions

Fields

allowMaxToDivergeFromCore

protected bool allowMaxToDivergeFromCore

Field Value

bool

completedTasks

protected int completedTasks

Field Value

int

corePoolSize

protected int corePoolSize

Field Value

int

keepAliveTime

protected TimeSpan keepAliveTime

Field Value

TimeSpan

maximumPoolSize

protected int maximumPoolSize

Field Value

int

queueSize

protected int queueSize

Field Value

int

queueSizeRejectionThreshold

protected int queueSizeRejectionThreshold

Field Value

int

runningTasks

protected int runningTasks

Field Value

int

runningThreads

protected int runningThreads

Field Value

int

shutdown

protected bool shutdown

Field Value

bool

Properties

CorePoolSize

public virtual int CorePoolSize { get; set; }

Property Value

int

CurrentActiveCount

public virtual int CurrentActiveCount { get; }

Property Value

int

CurrentCompletedTaskCount

public virtual int CurrentCompletedTaskCount { get; }

Property Value

int

CurrentCorePoolSize

public virtual int CurrentCorePoolSize { get; }

Property Value

int

CurrentLargestPoolSize

public virtual int CurrentLargestPoolSize { get; }

Property Value

int

CurrentMaximumPoolSize

public virtual int CurrentMaximumPoolSize { get; }

Property Value

int

CurrentPoolSize

public virtual int CurrentPoolSize { get; }

Property Value

int

CurrentQueueSize

public virtual int CurrentQueueSize { get; }

Property Value

int

CurrentTaskCount

public virtual int CurrentTaskCount { get; }

Property Value

int

IsQueueSpaceAvailable

public virtual bool IsQueueSpaceAvailable { get; }

Property Value

bool

IsShutdown

public bool IsShutdown { get; }

Property Value

bool

KeepAliveTime

public virtual TimeSpan KeepAliveTime { get; set; }

Property Value

TimeSpan

MaximumConcurrencyLevel

Indicates the maximum concurrency level this TaskScheduler is able to support.

public override int MaximumConcurrencyLevel { get; }

Property Value

int

Returns an integer that represents the maximum concurrency level. The default scheduler returns Int32.MaxValue.

MaximumPoolSize

public virtual int MaximumPoolSize { get; set; }

Property Value

int

Methods

Dispose()

Performs application-defined tasks associated with freeing, releasing, or resetting unmanaged resources.

public void Dispose()

Dispose(bool)

protected virtual void Dispose(bool disposing)

Parameters

disposing bool

RunContinuation(Task)

protected void RunContinuation(Task task)

Parameters

task Task