class

JoobQ::Worker(T)

Inherits Reference < Object

Constants

Log = ::Log.for("WORKER")
START = Time.instant

Constructors

new(wid : Int32, terminate_channel : Channel(Nil), queue : BaseQueue)
Source

Instance methods

active
Source
active?
Source
in_progress
Source
name
Source
running
Source
running?
Source
terminate
Source
worker_id
Source