class Movie::Scheduler

• Movie::Scheduler
• Reference
• Object

Overview

Centralized scheduler for managing timers within the actor system. Provides cancellable one-shot timers that execute callbacks after a delay. Uses the actor system's dispatcher for proper fiber management.

Example:

handle = scheduler.schedule_once(5.seconds) do
  puts "Timer fired!"
end
handle.cancel # Cancels the timer if not yet fired

Defined in:

movie/scheduler.cr

Constructors

• .new(dispatcher : Dispatcher)

Instance Method Summary

• #schedule_message(delay : Time::Span, target : ActorRef(T), message : T) : TimerHandle forall T

  Schedules a one-shot timer that sends a message to an actor after the given delay.

• #schedule_once(delay : Time::Span, &block : -> Nil) : TimerHandle

  Schedules a one-shot timer that executes the block after the given delay.

• #schedule_system_message(delay : Time::Span, target : ActorRefBase, message : SystemMessage) : TimerHandle

  Schedules a one-shot timer that sends a system message to an actor after the given delay.

• #stop : Nil

Constructor Detail

Instance Method Detail