ActiveRecord::ConnectionAdapters::FiberedMonitor::Queue

    # File lib/active_record/fiber_patches.rb, line 15
15:         def initialize
16:           @queue = []
17:         end

    # File lib/active_record/fiber_patches.rb, line 32
32:         def signal
33:           fiber = @queue.pop
34:           fiber.resume(true) if fiber
35:         end

    # File lib/active_record/fiber_patches.rb, line 19
19:         def wait(timeout)
20:           t = timeout || 5
21:           fiber = Fiber.current
22:           x = EM::Timer.new(t) do
23:             @queue.delete(fiber)
24:             fiber.resume(false)
25:           end
26:           @queue << fiber
27:           returning Fiber.yield do
28:             x.cancel
29:           end
30:         end