Sha256: 5eb731de9e5537cdea61e01db0e9f1d7b5bfba6f0be6cc09c7d7762a68566739
Contents?: true
Size: 648 Bytes
Versions: 40
Compression:
Stored size: 648 Bytes
Contents
require 'concurrent/atomic/count_down_latch'
module ActiveSupport
module Concurrency
class Latch
def initialize(count = 1)
if count == 1
ActiveSupport::Deprecation.warn("ActiveSupport::Concurrency::Latch is deprecated. Please use Concurrent::Event instead.")
else
ActiveSupport::Deprecation.warn("ActiveSupport::Concurrency::Latch is deprecated. Please use Concurrent::CountDownLatch instead.")
end
@inner = Concurrent::CountDownLatch.new(count)
end
def release
@inner.count_down
end
def await
@inner.wait(nil)
end
end
end
end
Version data entries
40 entries across 39 versions & 7 rubygems