new(spec) Class Public methods Creates a new ConnectionPool object. spec is a ConnectionSpecification object which describes database connection information (e.g. adapter, host name, username, password, etc), as well as the maximum size for this ConnectionPool. The default ConnectionPool maximum size is 5.

run() Instance Public methods

new(pool, frequency) Class Public methods

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

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

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

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

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

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

new(lock = Monitor.new) Class Public methods