Sha256: d47a80bdaca9b9516117d0201500daccaec852f1b948fcb266efd7264fbdb162
Contents?: true
Size: 1.18 KB
Versions: 104
Compression:
Stored size: 1.18 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
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
104 entries across 98 versions & 30 rubygems