Class HystrixSyncTaskScheduler

Namespace

Steeltoe.CircuitBreaker.Hystrix.Strategy.Concurrency

Assembly

Steeltoe.CircuitBreaker.HystrixBase.dll

public class HystrixSyncTaskScheduler : HystrixTaskScheduler, IHystrixTaskScheduler, IDisposable

Inheritance

object

TaskScheduler

HystrixTaskScheduler

HystrixSyncTaskScheduler

Implements

IHystrixTaskScheduler

IDisposable

Inherited Members

HystrixTaskScheduler.corePoolSize

HystrixTaskScheduler.keepAliveTime

HystrixTaskScheduler.maximumPoolSize

HystrixTaskScheduler.runningThreads

HystrixTaskScheduler.queueSizeRejectionThreshold

HystrixTaskScheduler.shutdown

HystrixTaskScheduler.queueSize

HystrixTaskScheduler.runningTasks

HystrixTaskScheduler.completedTasks

HystrixTaskScheduler.allowMaxToDivergeFromCore

HystrixTaskScheduler.CurrentActiveCount

HystrixTaskScheduler.CurrentCompletedTaskCount

HystrixTaskScheduler.CurrentCorePoolSize

HystrixTaskScheduler.CurrentLargestPoolSize

HystrixTaskScheduler.CurrentMaximumPoolSize

HystrixTaskScheduler.CurrentPoolSize

HystrixTaskScheduler.CurrentTaskCount

HystrixTaskScheduler.CorePoolSize

HystrixTaskScheduler.MaximumPoolSize

HystrixTaskScheduler.KeepAliveTime

HystrixTaskScheduler.Dispose()

HystrixTaskScheduler.MaximumConcurrencyLevel

HystrixTaskScheduler.IsShutdown

HystrixTaskScheduler.Dispose(bool)

HystrixTaskScheduler.RunContinuation(Task)

TaskScheduler.FromCurrentSynchronizationContext()

TaskScheduler.TryDequeue(Task)

TaskScheduler.TryExecuteTask(Task)

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

HystrixSyncTaskScheduler(IHystrixThreadPoolOptions)

public HystrixSyncTaskScheduler(IHystrixThreadPoolOptions options)

Parameters

options IHystrixThreadPoolOptions

Properties

CurrentQueueSize

public override int CurrentQueueSize { get; }

Property Value

int

IsQueueSpaceAvailable

public override bool IsQueueSpaceAvailable { get; }

Property Value

bool

Methods

GetScheduledTasks()

protected override IEnumerable<Task> GetScheduledTasks()

Returns

IEnumerable<Task>

QueueTask(Task)

protected override void QueueTask(Task task)

Parameters

task Task

SetupWorkQueues(int)

protected void SetupWorkQueues(int size)

Parameters

size int

StartThreadPoolWorker()

protected virtual void StartThreadPoolWorker()

StartThreadPoolWorker(ThreadTaskQueue)

protected virtual void StartThreadPoolWorker(HystrixSyncTaskScheduler.ThreadTaskQueue input)

Parameters

input HystrixSyncTaskScheduler.ThreadTaskQueue

TryAddToAny(Task)

protected virtual bool TryAddToAny(Task task)

Parameters

task Task

Returns

bool

TryExecuteTaskInline(Task, bool)

protected override bool TryExecuteTaskInline(Task task, bool prevQueued)

Parameters

task Task

prevQueued bool

Returns

bool