ruby-concurrency/concurrent-ruby

View on GitHub
lib/concurrent-ruby/concurrent/atomic_reference/numeric_cas_wrapper.rb

Summary

Maintainability
A
1 hr
Test Coverage
module Concurrent

  # Special "compare and set" handling of numeric values.
  #
  # @!visibility private
  # @!macro internal_implementation_note
  module AtomicNumericCompareAndSetWrapper

    # @!macro atomic_reference_method_compare_and_set
    def compare_and_set(old_value, new_value)
      if old_value.kind_of? Numeric
        while true
          old = get

          return false unless old.kind_of? Numeric

          return false unless old == old_value

          result = _compare_and_set(old, new_value)
          return result if result
        end
      else
        _compare_and_set(old_value, new_value)
      end
    end

  end
end