class

JoobQ::WorkerManager(T)

Inherits Reference < Object

WorkerManager handles all worker-related operations

Constants

Log = ::Log.for("WORKER_MANAGER")

Constructors

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

Instance methods

active_workers
Source
add_worker
Source
remove_worker
Source
resize(count : Int32) : Nil

Grows or shrinks the pool to count workers.

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