class

Movie::ExecutorExtension

Generic executor extension — runs arbitrary tasks on a bounded pool of workers.

Constructors

new(system : AbstractActorSystem, pool_size : Int32 = 4, queue_capacity : Int32 = 128)

execute(timeout : Time::Span | Nil = nil, &block : -> T) : Future(T) forall T

Execute a block and return a Future (existing API).

execute_with_reply(reply_to : ActorRef(TaskResult(T)), timeout : Time::Span | Nil = nil, &block : -> T) : Nil forall T

Execute a block and send the result back to a specific actor via a message.

start

Called when the extension is registered with the system. Override to perform initialization.

stop

Called when the system is shutting down. Override to cleanup resources (close connections, stop services, etc.)