AtomicBoolean and AtomicFixnum follow new subclass declaration convention.

Author: jdantonio

lib/concurrent/atomic/atomic_boolean.rb

@@ -62,7 +62,7 @@ def true?
       synchronize { @value }
     end
 
-    # @!macro atomic_boolean_method_false_question
+    # @!macro [attach] atomic_boolean_method_false_question
     #
     #   Is the current value `false`
     #
@@ -91,57 +91,54 @@ def make_false
 
     protected
 
+    # @!visibility private
     def ns_initialize(initial)
       @value = !!initial
     end
 
+    # @!visibility private
     def ns_make_value(value)
       old = @value
       @value = value
       old != @value
     end
   end
 
-  if Concurrent.on_jruby?
-
-    class AtomicBoolean < JavaAtomicBoolean
-    end
-
-  elsif defined?(CAtomicBoolean)
-
-    # @!macro atomic_boolean
-    class CAtomicBoolean
-
-      # @!method initialize
-      #   @!macro atomic_boolean_method_initialize
-
-      # @!method value
-      #   @!macro atomic_boolean_method_value_get
-
-      # @!method value=
-      #   @!macro atomic_boolean_method_value_set
-
-      # @!method true?
-      #   @!macro atomic_boolean_method_true_question
-
-      # @!method false?
-      #   @!macro atomic_boolean_method_false_question
-
-      # @!method make_true
-      #   @!macro atomic_boolean_method_make_true
-
-      # @!method make_false
-      #   @!macro atomic_boolean_method_make_false
-    end
-
-    # @!macro atomic_boolean
-    class AtomicBoolean < CAtomicBoolean
-    end
-
-  else
-
-    # @!macro atomic_boolean
-    class AtomicBoolean < MutexAtomicBoolean
-    end
+  AtomicBooleanImplementation = case
+                                when Concurrent.on_jruby?
+                                  JavaAtomicBoolean
+                                when defined?(CAtomicBoolean)
+                                  CAtomicBoolean
+                                else
+                                  MutexAtomicBoolean
+                                end
+  private_constant :AtomicBooleanImplementation
+
+  # @!macro atomic_boolean
+  #
+  # @see Concurrent::MutexAtomicBoolean
+  class AtomicBoolean < AtomicBooleanImplementation
+    
+    # @!method initialize(initial = false)
+    #   @!macro atomic_boolean_method_initialize
+    
+    # @!method value
+    #   @!macro atomic_boolean_method_value_get
+    
+    # @!method value=(value)
+    #   @!macro atomic_boolean_method_value_set
+    
+    # @!method true?
+    #   @!macro atomic_boolean_method_true_question
+    
+    # @!method false?
+    #   @!macro atomic_boolean_method_false_question
+    
+    # @!method make_true
+    #   @!macro atomic_boolean_method_make_true
+    
+    # @!method make_false
+    #   @!macro atomic_boolean_method_make_false
+    
   end
 end

lib/concurrent/atomic/atomic_fixnum.rb

@@ -90,7 +90,7 @@ def decrement
     #   @param [Fixnum] expect the expected value
     #   @param [Fixnum] update the new value
     #
-    #   @return [Boolean] true if the value was updated else false
+    #   @return [Fixnum] true if the value was updated else false
     def compare_and_set(expect, update)
       synchronize do
         if @value == expect
@@ -104,17 +104,20 @@ def compare_and_set(expect, update)
 
     protected
 
+    # @!visibility private
     def ns_initialize(initial)
       ns_set(initial)
     end
 
     private
 
+    # @!visibility private
     def ns_set(value)
       range_check!(value)
       @value = value
     end
 
+    # @!visibility private
     def range_check!(value)
       if !value.is_a?(Fixnum)
         raise ArgumentError.new('value value must be a Fixnum')
@@ -128,44 +131,38 @@ def range_check!(value)
     end
   end
 
-  if Concurrent.on_jruby?
-
-    # @!macro atomic_fixnum
-    class AtomicFixnum < JavaAtomicFixnum
-    end
-
-  elsif defined?(CAtomicFixnum)
-
-    # @!macro atomic_fixnum
-    class CAtomicFixnum
-
-      # @!method initialize
-      #   @!macro atomic_fixnum_method_initialize
-
-      # @!method value
-      #   @!macro atomic_fixnum_method_value_get
+  AtomicFixnumImplementation = case
+                               when Concurrent.on_jruby?
+                                 JavaAtomicFixnum
+                               when defined?(CAtomicFixnum)
+                                 CAtomicFixnum
+                               else
+                                 MutexAtomicFixnum
+                               end
+  private_constant :AtomicFixnumImplementation
+
+  # @!macro atomic_fixnum
+  #
+  # @see Concurrent::MutexAtomicFixnum
+  class AtomicFixnum < AtomicFixnumImplementation
+    
+    # @!method initialize(initial = 0)
+    #   @!macro atomic_fixnum_method_initialize
 
-      # @!method value=
-      #   @!macro atomic_fixnum_method_value_set
+    # @!method value
+    #   @!macro atomic_fixnum_method_value_get
 
-      # @!method increment
-      #   @!macro atomic_fixnum_method_increment
+    # @!method value=(value)
+    #   @!macro atomic_fixnum_method_value_set
 
-      # @!method decrement
-      #   @!macro atomic_fixnum_method_decrement
+    # @!method increment
+    #   @!macro atomic_fixnum_method_increment
 
-      # @!method compare_and_set
-      #   @!macro atomic_fixnum_method_compare_and_set
-    end
+    # @!method decrement
+    #   @!macro atomic_fixnum_method_decrement
 
-    # @!macro atomic_fixnum
-    class AtomicFixnum < CAtomicFixnum
-    end
+    # @!method compare_and_set(expect, update)
+    #   @!macro atomic_fixnum_method_compare_and_set
 
-  else
-
-    # @!macro atomic_fixnum
-    class AtomicFixnum < MutexAtomicFixnum
-    end
   end
 end