From c239a4f842a58b424974af013f9e266a21be1e39 Mon Sep 17 00:00:00 2001 From: Petr Chalupa Date: Sat, 3 Mar 2018 08:21:18 +0100 Subject: [PATCH] tmp --- lib/concurrent/actor/core.rb | 1 + lib/concurrent/executor/java_executor_service.rb | 2 ++ spec/spec_helper.rb | 2 +- 3 files changed, 4 insertions(+), 1 deletion(-) diff --git a/lib/concurrent/actor/core.rb b/lib/concurrent/actor/core.rb index 1546dfe0c..cde9b5485 100644 --- a/lib/concurrent/actor/core.rb +++ b/lib/concurrent/actor/core.rb @@ -90,6 +90,7 @@ def remove_child(child) # can be called from other alternative Reference implementations # @param [Envelope] envelope def on_envelope(envelope) + log(DEBUG) { "is #{envelope.future ? 'asked' : 'told'} #{envelope.message.inspect} by #{envelope.sender}" } schedule_execution do log(DEBUG) { "was #{envelope.future ? 'asked' : 'told'} #{envelope.message.inspect} by #{envelope.sender}" } process_envelope envelope diff --git a/lib/concurrent/executor/java_executor_service.rb b/lib/concurrent/executor/java_executor_service.rb index 5835d1f62..03b98be02 100644 --- a/lib/concurrent/executor/java_executor_service.rb +++ b/lib/concurrent/executor/java_executor_service.rb @@ -10,6 +10,7 @@ module Concurrent # @!visibility private class JavaExecutorService < AbstractExecutorService java_import 'java.lang.Runnable' + include Concern::Logging FALLBACK_POLICY_CLASSES = { abort: java.util.concurrent.ThreadPoolExecutor::AbortPolicy, @@ -26,6 +27,7 @@ def initialize(*args, &block) def post(*args, &task) raise ArgumentError.new('no block given') unless block_given? return handle_fallback(*args, &task) unless running? + log DEBUG, 'java-executor', args: args, task: task, caller: caller @executor.submit_runnable Job.new(args, task) true rescue Java::JavaUtilConcurrent::RejectedExecutionException diff --git a/spec/spec_helper.rb b/spec/spec_helper.rb index db5ccdad5..1a6bda487 100644 --- a/spec/spec_helper.rb +++ b/spec/spec_helper.rb @@ -22,7 +22,7 @@ require 'concurrent' require 'concurrent-edge' -Concurrent.use_simple_logger Logger::FATAL +Concurrent.use_simple_logger Logger::DEBUG require_relative 'support/example_group_extensions' require_relative 'support/less_than_or_equal_to_matcher'