Sha256: 9f9a5a6160599c2cd5e1732c9940610c52bb177a53df335fbf1c68ed3f6403e9
Contents?: true
Size: 748 Bytes
Versions: 26
Compression:
Stored size: 748 Bytes
Contents
require "thread"
module Bunny
module Concurrent
# Continuation queue implementation for MRI and Rubinius
#
# @private
class ContinuationQueue
def initialize(*args, &block)
@q = ::Queue.new(*args)
end
def push(*args)
@q.push(*args)
end
alias << push
def pop
@q.pop
end
def poll(timeout_in_ms = nil)
if timeout_in_ms
Bunny::Timeout.timeout(timeout_in_ms / 1000.0, ::Timeout::Error) do
@q.pop
end
else
@q.pop
end
end
def clear
@q.clear
end
def method_missing(selector, *args, &block)
@q.__send__(selector, *args, &block)
end
end
end
end
Version data entries
26 entries across 26 versions & 1 rubygems