class

JoobQ::WorkerManager(T)

Inherits Reference < Object

WorkerManager handles all worker-related operations

Constructors

new(total_workers : Int32, queue : Queue(T))
Source

Instance methods

active_workers
Source
add_worker
Source
remove_worker
Source
restart(worker, ex : Exception)
Source
running?
Source
running_workers
Source
start_workers
Source
stop_workers
Source
stopped
Source
stopped?
Source
terminate(worker)
Source
terminate_channel
Source
total_workers
Source
total_workers=(total_workers : Int32)
Source
workers
Source
workers_mutex
Source