Sha256: 3a215666129d5d05d3b2bf05c6de8cefb1e5b74baa8cf54b1b4ed4a51ab8bd26
Contents?: true
Size: 1.23 KB
Versions: 42
Compression:
Stored size: 1.23 KB
Contents
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
require 'thread' # get Mutex on 1.8
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
Version data entries
42 entries across 40 versions & 19 rubygems