# File lib/active_support/concurrency/latch.rb, line 7 def initialize(count = 1) @count = count @lock = Monitor.new @cv = @lock.new_cond end
# File lib/active_support/concurrency/latch.rb, line 20 def await @lock.synchronize do @cv.wait_while { @count > 0 } end end
# File lib/active_support/concurrency/latch.rb, line 13 def release @lock.synchronize do @count -= 1 if @count > 0 @cv.broadcast if @count.zero? end end