new(app) Class Public methods

call(env) Instance Public methods

new(lock = Monitor.new) Class Public methods

add(element) Instance Public methods Add element to the queue. Never blocks.

any_waiting?() Instance Public methods Test if any threads are currently waiting on the queue.

clear() Instance Public methods Remove all elements from the queue.

delete(element) Instance Public methods If element is in the queue, remove and return it, or nil.

num_waiting() Instance Public methods Returns the number of threads currently waiting on this queue.

poll(timeout = nil) Instance Public methods Remove the head of the queue. If timeout is not given, remove and return the head the queue if the number of available elements is strictly greater than the number of threads currently waiting (that is, don't jump ahead in line). Otherwise, return nil. If timeout is given, block if it there is no element available, waiting up to timeout seconds for an element to become available. Raises: ConnectionTimeoutError if timeout is given and no

new(pool, frequency) Class Public methods