Class: ActiveRecord::ConnectionAdapters::FiberedMonitor::Queue

Inherits:
Object
  • Object
show all
Defined in:
lib/active_record/patches.rb

Instance Method Summary collapse

Constructor Details

#initialize ⇒ Queue

Returns a new instance of Queue.



13
14
15
 
# File 'lib/active_record/patches.rb', line 13

def initialize
  @queue = []
end

Instance Method Details

#signal ⇒ Object 



30
31
32
33
 
# File 'lib/active_record/patches.rb', line 30

def signal
  fiber = @queue.pop
  fiber.resume(true) if fiber
end

#wait(timeout) ⇒ Object 



17
18
19
20
21
22
23
24
25
26
27
28
 
# File 'lib/active_record/patches.rb', line 17

def wait(timeout)
  t = timeout || 5
  fiber = Fiber.current
  x = EM::Timer.new(t) do
    @queue.delete(fiber)
    fiber.resume(false)
  end
  @queue << fiber
  Fiber.yield.tap do
    x.cancel
  end
end