class JoobQ::Worker(T)

Defined in:

joobq/worker.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(wid : Int32, terminate_channel : Channel(Nil), queue : BaseQueue) #

[View source]

Instance Method Detail

def active : Atomic(Bool) #

[View source]
def active? : Bool #

[View source]
def name #

[View source]
def run #

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

[View source]
def running? : Bool #

[View source]
def terminate #

[View source]
def wid : Int32 #

[View source]
def worker_id : String #

[View source]