class JoobQ::WorkerManager(T)

Overview

WorkerManager handles all worker-related operations

Defined in:

joobq/worker_manager.cr

Constructors

Instance Method Summary

Constructor Detail

def self.new(total_workers : Int32, queue : Queue(T)) #

[View source]

Instance Method Detail

def active_workers : Int32 #

[View source]
def add_worker #

[View source]
def remove_worker #

[View source]
def restart(worker, ex : Exception) #

[View source]
def running? : Bool #

[View source]
def running_workers : Int32 #

[View source]
def start_workers #

[View source]
def stop_workers #

[View source]
def stopped : Atomic(Bool) #

[View source]
def stopped? : Bool #

[View source]
def terminate(worker) #

[View source]
def terminate_channel : Channel(Nil) #

[View source]
def total_workers : Int32 #

[View source]
def total_workers=(total_workers : Int32) #

[View source]
def workers : Array(Worker(T)) #

[View source]
def workers_mutex #

[View source]