Gecko [ lorencats.com ]

Name	Size	Permission
adder.rb	2.17 KB	-rw-r--r--
atomic_reference.rb	1.18 KB	-rw-r--r--
cheap_lockable.rb	3.07 KB	-rw-r--r--
power_of_two_tuple.rb	610 B	-rw-r--r--
striped64.rb	8.83 KB	-rw-r--r--
volatile.rb	2.04 KB	-rw-r--r--
volatile_tuple.rb	1 KB	-rw-r--r--
xor_shift_random.rb	1.4 KB	-rw-r--r--

Name

Size

Permission

Action

adder.rb

2.17 KB

-rw-r--r--

atomic_reference.rb

1.18 KB

-rw-r--r--

cheap_lockable.rb

3.07 KB

-rw-r--r--

power_of_two_tuple.rb

610 B

-rw-r--r--

striped64.rb

8.83 KB

-rw-r--r--

volatile.rb

2.04 KB

-rw-r--r--

volatile_tuple.rb

1 KB

-rw-r--r--

xor_shift_random.rb

1.4 KB

-rw-r--r--

Code Editor : atomic_reference.rb

module ThreadSafe
  module Util
    AtomicReference =
      if defined?(Rubinius::AtomicReference)
        # An overhead-less atomic reference.
        Rubinius::AtomicReference
      else
        begin
          require 'atomic'
          defined?(Atomic::InternalReference) ? Atomic::InternalReference : Atomic
        rescue LoadError, NameError
          class FullLockingAtomicReference
            def initialize(value = nil)
              @___mutex = Mutex.new
              @___value = value
            end

def get
              @___mutex.synchronize { @___value }
            end
            alias_method :value, :get

def set(new_value)
              @___mutex.synchronize { @___value = new_value }
            end
            alias_method :value=, :set

def compare_and_set(old_value, new_value)
              return false unless @___mutex.try_lock
              begin
                return false unless @___value.equal? old_value
                @___value = new_value
              ensure
                @___mutex.unlock
              end
              true
            end
          end

FullLockingAtomicReference
        end
      end
  end
end

${this.title}

Code Editor : atomic_reference.rb