Sha256: 4eaa90a4e557d7563cc67c8e6d734f84e142e98fb4abca4002010a36f1649d2f
Contents?: true
Size: 834 Bytes
Versions: 16
Compression:
Stored size: 834 Bytes
Contents
# typed: false
module Datadog
module Core
module Workers
# Adds queue behavior to workers, with a buffer
# to which items can be queued then dequeued.
module Queue
def self.included(base)
base.prepend(PrependedMethods)
end
# Methods that must be prepended
module PrependedMethods
def perform(*args)
super(*dequeue) if work_pending?
end
end
def buffer
@buffer ||= []
end
def enqueue(*args)
buffer.push(args)
end
def dequeue
buffer.shift
end
# Are there more items to be processed next?
def work_pending?
!buffer.empty?
end
protected
attr_writer \
:buffer
end
end
end
end
Version data entries
16 entries across 16 versions & 1 rubygems