executor can have a name now

Author: AlexanderZagaynov

lib/concurrent/executor/abstract_executor_service.rb

@@ -16,10 +16,20 @@ class AbstractExecutorService < Synchronization::LockableObject
     # @!macro executor_service_attr_reader_fallback_policy
     attr_reader :fallback_policy
 
+    attr_reader :name
+
     # Create a new thread pool.
     def initialize(*args, &block)
       super(&nil)
-      synchronize { ns_initialize(*args, &block) }
+      synchronize do
+        ns_initialize(*args, &block)
+        opts = args.first || {}
+        @name = opts.fetch(:name) if opts.key?(:name)
+      end
+    end
+
+    def to_s
+      name ? "#{super[0..-2]} name: #{name}>" : super
     end
 
     # @!macro executor_service_method_shutdown

spec/concurrent/executor/thread_pool_executor_shared.rb

@@ -31,6 +31,10 @@
     it 'defaults :fallback_policy to :abort' do
       expect(subject.fallback_policy).to eq :abort
     end
+
+    it 'defaults :name to nil' do
+      expect(subject.name).to be_nil
+    end
   end
 
   context "#initialize explicit values" do
@@ -100,6 +104,13 @@
         described_class.new(fallback_policy: :bogus)
       }.to raise_error(ArgumentError)
     end
+
+    it 'sets :name' do
+      pool = described_class.new(name: 'MyPool')
+      expect(pool.name).to eq 'MyPool'
+      pool.shutdown
+      pool.wait_for_termination(pool_termination_timeout)
+    end
   end
 
   context '#max_queue' do