lib/never_block/pool/fibered_connection_pool.rb
# Check if there are waiting fibers and
# try to process them
Check if there are waiting fibers and
try to process them
Check if there are waiting fibers and try to process them
def process_queue
				while !@connections.empty? and !@queue.empty?
					fiber = @queue.shift
					fiber.resume @busy_connections[fiber] = @connections.shift
				end
			end
def process_queue while ! @connections . empty? and ! @queue . empty? fiber = @queue . shift fiber . resume @busy_connections [ fiber ] = @connections . shift end end
Check if there are waiting fibers and
try to process them
Check if there are waiting fibers and try to process them
# What is really happening here? # we are resuming a fiber from within # another, should we call transfer insted?