Threadsafe, fair, LIFO queue. Meant to be used by ConnectionPool
with which it shares a Monitor.
- A
- C
- D
- N
- P
Class Public methods
new(lock = Monitor.new) Link
Instance Public methods
add(element) Link
Add element
to the queue. Never blocks.
any_waiting?() Link
Test if any threads are currently waiting on the queue.
clear() Link
Remove all elements from the queue.
delete(element) Link
If element
is in the queue, remove and return it, or nil
.
num_waiting() Link
Returns the number of threads currently waiting on this queue.
poll(timeout = nil) Link
Remove the head of the queue.
If timeout
is not given, remove and return the head of 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 there is no element available, waiting up to timeout
seconds for an element to become available.
Raises:
-
ActiveRecord::ConnectionTimeoutError
iftimeout
is given and no element
becomes available within timeout
seconds,