Class HashedWheelTimerScheduler

This IScheduler implementation is built using a revolving wheel of buckets with each bucket belonging to a specific time resolution. As the "clock" of the scheduler ticks it advances to the next bucket in the circle and processes the items in it, and optionally reschedules recurring tasks into the future into the next relevant bucket.

There are akka.scheduler.ticks-per-wheel initial buckets (we round up to the nearest power of 2) with 512 being the initial default value. The timings are approximated and are still limited by the ceiling of the operating system's clock resolution.

Further reading: http://www.cs.columbia.edu/~nahum/w6998/papers/sosp87-timing-wheels.pdf Presentation: http://www.cse.wustl.edu/~cdgill/courses/cs6874/TimingWheels.ppt

Inheritance

Object

SchedulerBase

HashedWheelTimerScheduler

Implements

IScheduler

ITellScheduler

IAdvancedScheduler

IActionScheduler

IRunnableScheduler

IDateTimeOffsetNowTimeProvider

ITimeProvider

IDisposable

Inherited Members

SchedulerBase.SchedulerConfig

SchedulerBase.Log

SchedulerBase.ITellScheduler.ScheduleTellOnce(TimeSpan, ICanTell, Object, IActorRef)

SchedulerBase.ITellScheduler.ScheduleTellOnce(TimeSpan, ICanTell, Object, IActorRef, ICancelable)

SchedulerBase.ITellScheduler.ScheduleTellRepeatedly(TimeSpan, TimeSpan, ICanTell, Object, IActorRef)

SchedulerBase.ITellScheduler.ScheduleTellRepeatedly(TimeSpan, TimeSpan, ICanTell, Object, IActorRef, ICancelable)

SchedulerBase.IActionScheduler.ScheduleOnce(TimeSpan, Action)

SchedulerBase.IActionScheduler.ScheduleOnce(TimeSpan, Action, ICancelable)

SchedulerBase.IActionScheduler.ScheduleRepeatedly(TimeSpan, TimeSpan, Action)

SchedulerBase.IActionScheduler.ScheduleRepeatedly(TimeSpan, TimeSpan, Action, ICancelable)

SchedulerBase.IScheduler.Advanced

SchedulerBase.ITimeProvider.Now

SchedulerBase.ValidateInterval(TimeSpan, String)

SchedulerBase.ValidateDelay(TimeSpan, String)

SchedulerBase.ScheduleOnce(TimeSpan, IRunnable, ICancelable)

SchedulerBase.ScheduleOnce(TimeSpan, IRunnable)

SchedulerBase.ScheduleRepeatedly(TimeSpan, TimeSpan, IRunnable, ICancelable)

SchedulerBase.ScheduleRepeatedly(TimeSpan, TimeSpan, IRunnable)

Object.Equals(Object)

Object.Equals(Object, Object)

Object.GetHashCode()

Object.GetType()

Object.MemberwiseClone()

Object.ReferenceEquals(Object, Object)

Object.ToString()

Namespace: Akka.Actor

Assembly: Akka.dll

Syntax

public sealed class HashedWheelTimerScheduler : SchedulerBase, IScheduler, ITellScheduler, IAdvancedScheduler, IActionScheduler, IRunnableScheduler, IDateTimeOffsetNowTimeProvider, ITimeProvider, IDisposable

Constructors

HashedWheelTimerScheduler(Config, ILoggingAdapter)

TBD

Declaration

public HashedWheelTimerScheduler(Config scheduler, ILoggingAdapter log)

Parameters

Type	Name	Description
Config	scheduler	TBD
ILoggingAdapter	log	TBD

Exceptions

Type	Condition
ArgumentOutOfRangeException	TBD

Properties

HighResMonotonicClock

TBD

Declaration

public override TimeSpan HighResMonotonicClock { get; }

Property Value

Type	Description
TimeSpan

Overrides

SchedulerBase.HighResMonotonicClock

MonotonicClock

TBD

Declaration

public override TimeSpan MonotonicClock { get; }

Property Value

Type	Description
TimeSpan

Overrides

SchedulerBase.MonotonicClock

TimeNow

TBD

Declaration

protected override DateTimeOffset TimeNow { get; }

Property Value

Type	Description
DateTimeOffset

Overrides

SchedulerBase.TimeNow

Methods

Dispose()

Declaration

public void Dispose()

InternalScheduleOnce(TimeSpan, IRunnable, ICancelable)

Declaration

protected override void InternalScheduleOnce(TimeSpan delay, IRunnable action, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	delay
IRunnable	action
ICancelable	cancelable

Overrides

SchedulerBase.InternalScheduleOnce(TimeSpan, IRunnable, ICancelable)

InternalScheduleOnce(TimeSpan, Action, ICancelable)

TBD

Declaration

protected override void InternalScheduleOnce(TimeSpan delay, Action action, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	delay	TBD
Action	action	TBD
ICancelable	cancelable	TBD

Overrides

SchedulerBase.InternalScheduleOnce(TimeSpan, Action, ICancelable)

InternalScheduleRepeatedly(TimeSpan, TimeSpan, IRunnable, ICancelable)

Declaration

protected override void InternalScheduleRepeatedly(TimeSpan initialDelay, TimeSpan interval, IRunnable action, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	initialDelay
TimeSpan	interval
IRunnable	action
ICancelable	cancelable

Overrides

SchedulerBase.InternalScheduleRepeatedly(TimeSpan, TimeSpan, IRunnable, ICancelable)

InternalScheduleRepeatedly(TimeSpan, TimeSpan, Action, ICancelable)

TBD

Declaration

protected override void InternalScheduleRepeatedly(TimeSpan initialDelay, TimeSpan interval, Action action, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	initialDelay	TBD
TimeSpan	interval	TBD
Action	action	TBD
ICancelable	cancelable	TBD

Overrides

SchedulerBase.InternalScheduleRepeatedly(TimeSpan, TimeSpan, Action, ICancelable)

InternalScheduleTellOnce(TimeSpan, ICanTell, Object, IActorRef, ICancelable)

TBD

Declaration

protected override void InternalScheduleTellOnce(TimeSpan delay, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	delay	TBD
ICanTell	receiver	TBD
Object	message	TBD
IActorRef	sender	TBD
ICancelable	cancelable	TBD

Overrides

SchedulerBase.InternalScheduleTellOnce(TimeSpan, ICanTell, Object, IActorRef, ICancelable)

InternalScheduleTellRepeatedly(TimeSpan, TimeSpan, ICanTell, Object, IActorRef, ICancelable)

TBD

Declaration

protected override void InternalScheduleTellRepeatedly(TimeSpan initialDelay, TimeSpan interval, ICanTell receiver, object message, IActorRef sender, ICancelable cancelable)

Parameters

Type	Name	Description
TimeSpan	initialDelay	TBD
TimeSpan	interval	TBD
ICanTell	receiver	TBD
Object	message	TBD
IActorRef	sender	TBD
ICancelable	cancelable	TBD

Overrides

SchedulerBase.InternalScheduleTellRepeatedly(TimeSpan, TimeSpan, ICanTell, Object, IActorRef, ICancelable)

Implements

IScheduler

ITellScheduler

IAdvancedScheduler

IActionScheduler

IRunnableScheduler

IDateTimeOffsetNowTimeProvider

ITimeProvider

IDisposable

Extension Methods

ObjectExtensions.IsDefaultForType<T>(T)

SchedulerExtensions.ScheduleTellOnce(ITellScheduler, Int32, ICanTell, Object, IActorRef, ICancelable)

SchedulerExtensions.ScheduleTellRepeatedly(ITellScheduler, Int32, Int32, ICanTell, Object, IActorRef, ICancelable)

SchedulerExtensions.ScheduleTellOnceCancelable(IScheduler, TimeSpan, ICanTell, Object, IActorRef)

SchedulerExtensions.ScheduleTellOnceCancelable(IScheduler, Int32, ICanTell, Object, IActorRef)

SchedulerExtensions.ScheduleTellRepeatedlyCancelable(IScheduler, TimeSpan, TimeSpan, ICanTell, Object, IActorRef)

SchedulerExtensions.ScheduleTellRepeatedlyCancelable(IScheduler, Int32, Int32, ICanTell, Object, IActorRef)

SchedulerExtensions.ScheduleOnce(IActionScheduler, Int32, Action, ICancelable)

SchedulerExtensions.ScheduleRepeatedly(IActionScheduler, Int32, Int32, Action, ICancelable)

SchedulerExtensions.ScheduleOnceCancelable(IActionScheduler, TimeSpan, Action)

SchedulerExtensions.ScheduleOnceCancelable(IActionScheduler, Int32, Action)

SchedulerExtensions.ScheduleRepeatedlyCancelable(IActionScheduler, TimeSpan, TimeSpan, Action)

SchedulerExtensions.ScheduleRepeatedlyCancelable(IActionScheduler, Int32, Int32, Action)

ObjectExtensions.AsOption<T>(T)

Extensions.AsInstanceOf<T>(Object)