Merge pull request #319 from ruby-concurrency/internal-reorg-concerns

Moved mixins to the `Concern` module

Author: jdantonio

lib/concurrent/actor.rb

@@ -1,6 +1,5 @@
 require 'concurrent/configuration'
 require 'concurrent/executor/serialized_execution'
-require 'concurrent/logging'
 require 'concurrent/synchronization'
 require 'concurrent/edge/future'
 

lib/concurrent/actor/behaviour/abstract.rb

@@ -1,9 +1,12 @@
+require 'concurrent/concern/logging'
+
 module Concurrent
   module Actor
     module Behaviour
       class Abstract
         include TypeCheck
         include InternalDelegations
+        include Concern::Logging
 
         attr_reader :core, :subsequent
 
@@ -39,7 +42,7 @@ def broadcast(public, event)
         def reject_envelope(envelope)
           envelope.reject! ActorTerminated.new(reference)
           dead_letter_routing << envelope unless envelope.future
-          log Logging::DEBUG, "rejected #{envelope.message} from #{envelope.sender_path}"
+          log DEBUG, "rejected #{envelope.message} from #{envelope.sender_path}"
         end
       end
     end

lib/concurrent/actor/behaviour/sets_results.rb

@@ -14,11 +14,11 @@ def on_envelope(envelope)
           result = pass envelope
           if result != MESSAGE_PROCESSED && !envelope.future.nil?
             envelope.future.success result
-            log Logging::DEBUG, "finished processing of #{envelope.message.inspect}"
+            log DEBUG, "finished processing of #{envelope.message.inspect}"
           end
           nil
         rescue => error
-          log Logging::ERROR, error
+          log ERROR, error
           case error_strategy
           when :terminate!
             terminate!

lib/concurrent/actor/context.rb

@@ -1,3 +1,5 @@
+require 'concurrent/concern/logging'
+
 module Concurrent
   module Actor
 
@@ -22,6 +24,7 @@ module Actor
     class AbstractContext
       include TypeCheck
       include InternalDelegations
+      include Concern::Logging
 
       attr_reader :core
 

lib/concurrent/actor/core.rb

@@ -1,3 +1,4 @@
+require 'concurrent/concern/logging'
 require 'concurrent/executors'
 
 module Concurrent
@@ -11,7 +12,7 @@ module Actor
     #   that would eat up all threads in task pool and deadlock
     class Core < Synchronization::Object
       include TypeCheck
-      include Concurrent::Logging
+      include Concern::Logging
 
       # @!attribute [r] reference
       #   Reference to this actor which can be safely passed around.
@@ -44,7 +45,7 @@ class Core < Synchronization::Object
       # @option opts [CompletableFuture, nil] initialized, if present it'll be set or failed after {Context} initialization
       # @option opts [Reference, nil] parent **private api** parent of the actor (the one spawning )
       # @option opts [Proc, nil] logger a proc accepting (level, progname, message = nil, &block) params,
-      #   can be used to hook actor instance to any logging system, see {Concurrent::Logging}
+      #   can be used to hook actor instance to any logging system, see {Concurrent::Concern::Logging}
       # @param [Proc] block for class instantiation
       def initialize(opts = {}, &block)
         super(&nil)
@@ -127,7 +128,7 @@ def schedule_execution
       end
 
       def broadcast(public, event)
-        log Logging::DEBUG, "event: #{event.inspect} (#{public ? 'public' : 'private'})"
+        log DEBUG, "event: #{event.inspect} (#{public ? 'public' : 'private'})"
         @first_behaviour.on_event(public, event)
       end
 

lib/concurrent/actor/default_dead_letter_handler.rb

@@ -2,7 +2,7 @@ module Concurrent
   module Actor
     class DefaultDeadLetterHandler < RestartingContext
       def on_message(dead_letter)
-        log Logging::INFO, "got dead letter #{dead_letter.inspect}"
+        log INFO, "got dead letter #{dead_letter.inspect}"
       end
     end
   end

lib/concurrent/agent.rb

@@ -1,9 +1,9 @@
 require 'thread'
-require 'concurrent/dereferenceable'
-require 'concurrent/observable'
-require 'concurrent/logging'
+require 'concurrent/concern/dereferenceable'
+require 'concurrent/concern/observable'
+require 'concurrent/concern/logging'
 require 'concurrent/executor/executor'
-require 'concurrent/utility/deprecation'
+require 'concurrent/concern/deprecation'
 
 module Concurrent
 
@@ -79,10 +79,10 @@ module Concurrent
   # @!attribute [r] timeout
   #   @return [Fixnum] the maximum number of seconds before an update is cancelled
   class Agent
-    include Dereferenceable
-    include Observable
-    include Logging
-    include Deprecation
+    include Concern::Dereferenceable
+    include Concern::Observable
+    include Concern::Logging
+    include Concern::Deprecation
 
     attr_reader :timeout, :io_executor, :fast_executor
 

lib/concurrent/async.rb

@@ -79,7 +79,7 @@ module Concurrent
   #   horn.async.echo('one') # asynchronous, non-blocking, thread-safe
   #   horn.await.echo('two') # synchronous, blocking, thread-safe
   #
-  # @see Concurrent::Obligation
+  # @see Concurrent::Concern::Obligation
   # @see Concurrent::IVar
   module Async
 

lib/concurrent/atom.rb

@@ -1,4 +1,4 @@
-require 'concurrent/dereferenceable'
+require 'concurrent/concern/dereferenceable'
 require 'concurrent/atomic/atomic_reference'
 require 'concurrent/synchronization/object'
 
@@ -22,7 +22,7 @@ module Concurrent
   #
   # @see http://clojure.org/atoms Clojure Atoms
   class Atom < Synchronization::Object
-    include Dereferenceable
+    include Concern::Dereferenceable
 
     # Create a new atom with the given initial value.
     #

lib/concurrent/atomic/condition.rb

@@ -1,5 +1,5 @@
 require 'concurrent/utility/monotonic_time'
-require 'concurrent/utility/deprecation'
+require 'concurrent/concern/deprecation'
 
 module Concurrent
 
@@ -15,7 +15,7 @@ module Concurrent
   #
   # @deprecated
   class Condition
-    include Deprecation
+    include Concern::Deprecation
 
     class Result
       def initialize(remaining_time)