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 : mutex_semaphore.rb

require 'concurrent/synchronization'
require 'concurrent/utility/native_integer'

module Concurrent

# @!macro semaphore
  # @!visibility private
  # @!macro internal_implementation_note
  class MutexSemaphore < Synchronization::LockableObject

# @!macro semaphore_method_initialize
    def initialize(count)
      Utility::NativeInteger.ensure_integer_and_bounds count

super()
      synchronize { ns_initialize count }
    end

# @!macro semaphore_method_acquire
    def acquire(permits = 1)
      Utility::NativeInteger.ensure_integer_and_bounds permits
      Utility::NativeInteger.ensure_positive permits

synchronize do
        try_acquire_timed(permits, nil)
        nil
      end
    end

# @!macro semaphore_method_available_permits
    def available_permits
      synchronize { @free }
    end

# @!macro semaphore_method_drain_permits
    #
    #   Acquires and returns all permits that are immediately available.
    #
    #   @return [Integer]
    def drain_permits
      synchronize do
        @free.tap { |_| @free = 0 }
      end
    end

# @!macro semaphore_method_try_acquire
    def try_acquire(permits = 1, timeout = nil)
      Utility::NativeInteger.ensure_integer_and_bounds permits
      Utility::NativeInteger.ensure_positive permits

synchronize do
        if timeout.nil?
          try_acquire_now(permits)
        else
          try_acquire_timed(permits, timeout)
        end
      end
    end

# @!macro semaphore_method_release
    def release(permits = 1)
      Utility::NativeInteger.ensure_integer_and_bounds permits
      Utility::NativeInteger.ensure_positive permits

synchronize do
        @free += permits
        permits.times { ns_signal }
      end
      nil
    end

# Shrinks the number of available permits by the indicated reduction.
    #
    # @param [Fixnum] reduction Number of permits to remove.
    #
    # @raise [ArgumentError] if `reduction` is not an integer or is negative
    #
    # @raise [ArgumentError] if `@free` - `@reduction` is less than zero
    #
    # @return [nil]
    #
    # @!visibility private
    def reduce_permits(reduction)
      Utility::NativeInteger.ensure_integer_and_bounds reduction
      Utility::NativeInteger.ensure_positive reduction

synchronize { @free -= reduction }
      nil
    end

protected

# @!visibility private
    def ns_initialize(count)
      @free = count
    end

private

# @!visibility private
    def try_acquire_now(permits)
      if @free >= permits
        @free -= permits
        true
      else
        false
      end
    end

# @!visibility private
    def try_acquire_timed(permits, timeout)
      ns_wait_until(timeout) { try_acquire_now(permits) }
    end
  end
end

${this.title}

Code Editor : mutex_semaphore.rb