Sha256: acc3623ac4989b1d273594b0af8644825741fab21e4e8c0ae64320d6fb5dd567
Contents?: true
Size: 1.27 KB
Versions: 31
Compression:
Stored size: 1.27 KB
Contents
require 'concurrent/synchronization'
require 'concurrent/utility/engine'
require 'concurrent/atomic_reference/concurrent_update_error'
require 'concurrent/atomic_reference/mutex_atomic'
begin
# force fallback impl with FORCE_ATOMIC_FALLBACK=1
if /[^0fF]/ =~ ENV['FORCE_ATOMIC_FALLBACK']
ruby_engine = 'mutex_atomic'
else
ruby_engine = Concurrent.ruby_engine
end
require "concurrent/atomic_reference/#{ruby_engine}"
rescue LoadError
#warn 'Compiled extensions not installed, pure Ruby Atomic will be used.'
end
if defined? Concurrent::JavaAtomicReference
# @!macro atomic_reference
class Concurrent::AtomicReference < Concurrent::JavaAtomicReference
end
elsif defined? Concurrent::RbxAtomicReference
# @!macro atomic_reference
class Concurrent::AtomicReference < Concurrent::RbxAtomicReference
end
elsif defined? Concurrent::CAtomicReference
# @!macro atomic_reference
class Concurrent::AtomicReference < Concurrent::CAtomicReference
end
else
# @!macro atomic_reference
class Concurrent::AtomicReference < Concurrent::MutexAtomicReference
end
end
class Concurrent::AtomicReference
# @return [String] Short string representation.
def to_s
format '<#%s:0x%x value:%s>', self.class, object_id << 1, get
end
alias_method :inspect, :to_s
end
Version data entries
31 entries across 28 versions & 9 rubygems