log ignored exceptions on DEBUG level

Author: pitr-ch

lib/concurrent/actress.rb

@@ -1,5 +1,3 @@
-require 'logger'
-
 require 'concurrent/configuration'
 require 'concurrent/executor/one_by_one'
 require 'concurrent/ivar'

lib/concurrent/agent.rb

@@ -4,6 +4,7 @@
 require 'concurrent/observable'
 require 'concurrent/options_parser'
 require 'concurrent/utility/timeout'
+require 'concurrent/logging'
 
 module Concurrent
 
@@ -35,6 +36,7 @@ module Concurrent
   class Agent
     include Dereferenceable
     include Concurrent::Observable
+    include Logging
 
     # The default timeout value (in seconds); used when no timeout option
     # is given at initialization
@@ -192,7 +194,8 @@ def try_rescue(ex) # :nodoc:
       end
       rescuer.block.call(ex) if rescuer
     rescue Exception => ex
-      # supress
+      # suppress
+      log DEBUG, ex
     end
 
     # @!visibility private

lib/concurrent/configuration.rb

@@ -6,6 +6,7 @@
 require 'concurrent/utility/processor_count'
 
 module Concurrent
+  extend Logging
 
   # A gem-level configuration object.
   class Configuration
@@ -134,7 +135,8 @@ def self.finalize_executor(executor)
       executor.kill
     end
     true
-  rescue
+  rescue => ex
+    log DEBUG, ex
     false
   end
 

lib/concurrent/executor/executor.rb

@@ -1,4 +1,5 @@
 require 'concurrent/errors'
+require 'concurrent/logging'
 require 'concurrent/atomic/event'
 
 module Concurrent
@@ -11,6 +12,7 @@ def can_overflow?
 
   module RubyExecutor
     include Executor
+    include Logging
 
     # Submit a task to the executor for asynchronous processing.
     #

lib/concurrent/executor/ruby_single_thread_executor.rb

@@ -64,6 +64,7 @@ def work
           task.last.call(*task.first)
         rescue => ex
           # let it fail
+          log DEBUG, ex
         end
       end
       stopped_event.set

lib/concurrent/executor/ruby_thread_pool_executor.rb

@@ -237,8 +237,9 @@ def handle_overflow(*args)
       when :caller_runs
         begin
           yield(*args)
-        rescue
+        rescue => ex
           # let it fail
+          log DEBUG, ex
         end
         true
       end

lib/concurrent/executor/ruby_thread_pool_worker.rb

@@ -1,9 +1,11 @@
 require 'thread'
+require 'concurrent/logging'
 
 module Concurrent
 
   # @!visibility private
   class RubyThreadPoolWorker
+    include Logging
 
     # @!visibility private
     def initialize(queue, parent)
@@ -59,6 +61,7 @@ def run(thread = Thread.current)
           task.last.call(*task.first)
         rescue => ex
           # let it fail
+          log DEBUG, ex
         ensure
           @last_activity = Time.now.to_f
           @parent.on_end_task