changed Synchronization methods from private to protected.

Author: jdantonio

lib/concurrent/executor/executor_service.rb

@@ -13,8 +13,8 @@ class AbstractExecutorService < Synchronization::Object
 
     attr_reader :fallback_policy
 
-    def initialize
-      super()
+    def initialize(*args, &block)
+      super
     end
 
     # @!macro [attach] executor_service_method_running_question
@@ -172,12 +172,11 @@ def terminate_at_exit
 
   class RubyExecutorService < AbstractExecutorService
 
-    def initialize
-      super()
-      synchronize do
-        @stop_event    = Event.new
-        @stopped_event = Event.new
-      end
+    def initialize(*args, &block)
+      super
+      @stop_event    = Event.new
+      @stopped_event = Event.new
+      ensure_ivar_visibility!
     end
 
     def post(*args, &task)
@@ -249,8 +248,8 @@ class JavaExecutorService < AbstractExecutorService
       }.freeze
       private_constant :FALLBACK_POLICY_CLASSES
 
-      def initialize
-        super()
+      def initialize(*args, &block)
+        super
       end
 
       def post(*args, &task)

lib/concurrent/synchronization/abstract_object.rb

@@ -32,7 +32,7 @@ def initialize(*args, &block)
         raise NotImplementedError
       end
 
-      private
+      protected
 
       # @yield runs the block synchronized against this object,
       #   equivalent of java's `synchronize(this) {}`

lib/concurrent/synchronization/java_pure_object.rb

@@ -9,7 +9,7 @@ def initialize(*args, &block)
           synchronize { ns_initialize(*args, &block) }
         end
 
-        private
+        protected
 
         def synchronize
           JRuby.reference0(self).synchronized { yield }

lib/concurrent/synchronization/monitor_object.rb

@@ -7,7 +7,7 @@ def initialize(*args, &block)
         synchronize { ns_initialize(*args, &block) }
       end
 
-      private
+      protected
 
       def synchronize
         @__lock__.synchronize { yield }

lib/concurrent/synchronization/mutex_object.rb

@@ -7,7 +7,7 @@ def initialize(*args, &block)
         synchronize { ns_initialize(*args, &block) }
       end
 
-      private
+      protected
 
       def synchronize
         if @__lock__.owned?

lib/concurrent/synchronization/rbx_object.rb

@@ -9,7 +9,7 @@ def initialize(*args, &block)
           end
         end
 
-        private
+        protected
 
         def synchronize(&block)
           Rubinius.synchronize(self, &block)