class EventBus::TaskRunner

• EventBus::TaskRunner
• Reference
• Object

Defined in:

eventbus/task.cr

Constant Summary

WAIT_TIME = 5.second

Constructors

• .new(job_count : Int32)

Instance Method Summary

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

Constructor Detail

Instance Method Detail