Sha256: 4699480f889ffbe561610cba3619bd194e4e8f90894bd5d5651a54488aec3ddc
Contents?: true
Size: 488 Bytes
Versions: 132
Compression:
Stored size: 488 Bytes
Contents
require 'thread'
require 'monitor'
module ActiveSupport
module Concurrency
class Latch
def initialize(count = 1)
@count = count
@lock = Monitor.new
@cv = @lock.new_cond
end
def release
@lock.synchronize do
@count -= 1 if @count > 0
@cv.broadcast if @count.zero?
end
end
def await
@lock.synchronize do
@cv.wait_while { @count > 0 }
end
end
end
end
end
Version data entries
132 entries across 127 versions & 13 rubygems