Sha256: 312871a0766f99294ad77236d0e08be99326bee46dc2f71d3af1904b65798ad5
Contents?: true
Size: 964 Bytes
Versions: 91
Compression:
Stored size: 964 Bytes
Contents
if Concurrent.on_jruby?
module Concurrent
# @!macro count_down_latch
# @!visibility private
# @!macro internal_implementation_note
class JavaCountDownLatch
# @!macro count_down_latch_method_initialize
def initialize(count = 1)
unless count.is_a?(Fixnum) && count >= 0
raise ArgumentError.new('count must be in integer greater than or equal zero')
end
@latch = java.util.concurrent.CountDownLatch.new(count)
end
# @!macro count_down_latch_method_wait
def wait(timeout = nil)
if timeout.nil?
@latch.await
true
else
@latch.await(1000 * timeout, java.util.concurrent.TimeUnit::MILLISECONDS)
end
end
# @!macro count_down_latch_method_count_down
def count_down
@latch.countDown
end
# @!macro count_down_latch_method_count
def count
@latch.getCount
end
end
end
end
Version data entries
91 entries across 85 versions & 22 rubygems