Gecko [ lorencats.com ]

Name	Size	Permission
abstract_thread_local_var.rb	1.3 KB	-rw-r--r--
atomic_boolean.rb	3.8 KB	-rw-r--r--
atomic_fixnum.rb	4.51 KB	-rw-r--r--
atomic_reference.rb	1.27 KB	-rw-r--r--
count_down_latch.rb	3.24 KB	-rw-r--r--
cyclic_barrier.rb	3.99 KB	-rw-r--r--
event.rb	2.76 KB	-rw-r--r--
java_count_down_latch.rb	964 B	-rw-r--r--
java_thread_local_var.rb	691 B	-rw-r--r--
mutex_atomic_boolean.rb	1.23 KB	-rw-r--r--
mutex_atomic_fixnum.rb	1.55 KB	-rw-r--r--
mutex_count_down_latch.rb	970 B	-rw-r--r--
mutex_semaphore.rb	2.7 KB	-rw-r--r--
read_write_lock.rb	8.22 KB	-rw-r--r--
reentrant_read_write_lock.rb	13.87 KB	-rw-r--r--
ruby_thread_local_var.rb	4.85 KB	-rw-r--r--
semaphore.rb	4.15 KB	-rw-r--r--
thread_local_var.rb	3.01 KB	-rw-r--r--

Code Editor : count_down_latch.rb

require 'concurrent/atomic/mutex_count_down_latch'
require 'concurrent/atomic/java_count_down_latch'
require 'concurrent/utility/engine'

module Concurrent

###################################################################

# @!macro [new] count_down_latch_method_initialize
  #
  #   Create a new `CountDownLatch` with the initial `count`.
  #
  #   @param [new] count the initial count
  #
  #   @raise [ArgumentError] if `count` is not an integer or is less than zero

# @!macro [new] count_down_latch_method_wait
  #
  #   Block on the latch until the counter reaches zero or until `timeout` is reached.
  #
  #   @param [Fixnum] timeout the number of seconds to wait for the counter or `nil`
  #     to block indefinitely
  #   @return [Boolean] `true` if the `count` reaches zero else false on `timeout`

# @!macro [new] count_down_latch_method_count_down
  #
  #   Signal the latch to decrement the counter. Will signal all blocked threads when
  #   the `count` reaches zero.

# @!macro [attach] count_down_latch_method_count
  #
  #   The current value of the counter.
  #
  #   @return [Fixnum] the current value of the counter

###################################################################

# @!macro [new] count_down_latch_public_api
  #
  #   @!method initialize(count = 1)
  #     @!macro count_down_latch_method_initialize
  #
  #   @!method wait(timeout = nil)
  #     @!macro count_down_latch_method_wait
  #
  #   @!method count_down
  #     @!macro count_down_latch_method_count_down
  #
  #   @!method count
  #     @!macro count_down_latch_method_count

###################################################################

# @!visibility private
  # @!macro internal_implementation_note
  CountDownLatchImplementation = case
                                 when Concurrent.on_jruby?
                                   JavaCountDownLatch
                                 else
                                   MutexCountDownLatch
                                 end
  private_constant :CountDownLatchImplementation

# @!macro [attach] count_down_latch
  #
  #   A synchronization object that allows one thread to wait on multiple other threads.
  #   The thread that will wait creates a `CountDownLatch` and sets the initial value
  #   (normally equal to the number of other threads). The initiating thread passes the
  #   latch to the other threads then waits for the other threads by calling the `#wait`
  #   method. Each of the other threads calls `#count_down` when done with its work.
  #   When the latch counter reaches zero the waiting thread is unblocked and continues
  #   with its work. A `CountDownLatch` can be used only once. Its value cannot be reset.
  #
  # @!macro count_down_latch_public_api
  # @example Waiter and Decrementer
  #   latch = Concurrent::CountDownLatch.new(3)
  #
  #   waiter = Thread.new do
  #     latch.wait()
  #     puts ("Waiter released")
  #   end
  #
  #   decrementer = Thread.new do
  #     sleep(1)
  #     latch.count_down
  #     puts latch.count
  #
  #     sleep(1)
  #     latch.count_down
  #     puts latch.count
  #
  #     sleep(1)
  #     latch.count_down
  #     puts latch.count
  #   end
  #
  #   [waiter, decrementer].each(&:join)
  class CountDownLatch < CountDownLatchImplementation
  end
end

${this.title}

Code Editor : count_down_latch.rb