Contents

require 'concurrent/synchronization'

module Concurrent

  # @!macro count_down_latch
  # @!visibility private
  # @!macro internal_implementation_note
  class MutexCountDownLatch < Synchronization::LockableObject

    # @!macro count_down_latch_method_initialize
    def initialize(count = 1)
      Utility::NativeInteger.ensure_integer_and_bounds count
      Utility::NativeInteger.ensure_positive count

      super()
      synchronize { ns_initialize count }
    end

    # @!macro count_down_latch_method_wait
    def wait(timeout = nil)
      synchronize { ns_wait_until(timeout) { @count == 0 } }
    end

    # @!macro count_down_latch_method_count_down
    def count_down
      synchronize do
        @count -= 1 if @count > 0
        ns_broadcast if @count == 0
      end
    end

    # @!macro count_down_latch_method_count
    def count
      synchronize { @count }
    end

    protected

    def ns_initialize(count)
      @count = count
    end
  end
end

Version data entries

43 entries across 40 versions & 11 rubygems

Version	Path
concurrent-ruby-1.0.4	lib/concurrent/atomic/mutex_count_down_latch.rb
concurrent-ruby-1.0.3-java	lib/concurrent/atomic/mutex_count_down_latch.rb
concurrent-ruby-1.0.3	lib/concurrent/atomic/mutex_count_down_latch.rb