Sha256: 1512d6b48880284e768de3da282b18c5b0fe1698c651b16cf48112f8a78d66f4
Contents?: true
Size: 618 Bytes
Versions: 8
Compression:
Stored size: 618 Bytes
Contents
module Sidekiq
class Queue
extend LimitFetch::Instances, Forwardable
attr_reader :rname
def_delegators :lock,
:limit, :limit=, :limit_changed?,
:process_limit, :process_limit=,
:acquire, :release,
:pause, :pause_for_ms, :unpause,
:block, :unblock,
:paused?, :blocking?,
:unblocked, :block_except,
:probed, :busy,
:increase_busy, :decrease_busy,
:local_busy?, :explain,
:remove_locks_except!
def lock
@lock ||= LimitFetch::Global::Semaphore.new name
end
end
end
Version data entries
8 entries across 8 versions & 2 rubygems