class

EventBus::TaskRunner

Inherits Reference < Object

Constants

WAIT_TIME = 5.second

Constructors

new(job_count : Int32)
Source

Instance methods

add_task(task : Task)
Source
cancel_task(task_id : String) : Nil
Source
get_job?
Source
has?(task_id : String, pending_only = false) : Bool
Source
job_done(id : String) : Nil
Source
lock
Source
running
Source
start
Source
stop
Source
tasks
Source