chore: define inspect method for concurrent worker (#276)

Author: supercaracal

lib/redis_client/cluster/concurrent_worker.rb

@@ -7,7 +7,7 @@
 class RedisClient
   class Cluster
     module ConcurrentWorker
-      InvalidNumberOfTasks = Class.new(::RedisClient::Error)
+      InvalidNumberOfTasks = Class.new(StandardError)
 
       class Group
         Task = Struct.new(
@@ -63,6 +63,10 @@ def close
           @count = 0
           nil
         end
+
+        def inspect
+          "#<#{self.class.name} size: #{@count}, max: #{@size}, worker: #{@worker.class.name}>"
+        end
       end
 
       module_function

lib/redis_client/cluster/concurrent_worker/none.rb

@@ -17,6 +17,10 @@ def push(task)
         end
 
         def close; end
+
+        def inspect
+          "#<#{self.class.name} main thread only>"
+        end
       end
     end
   end

lib/redis_client/cluster/concurrent_worker/on_demand.rb

@@ -26,6 +26,10 @@ def close
           nil
         end
 
+        def inspect
+          "#<#{self.class.name} active: #{@q.size}, max: #{@q.max}>"
+        end
+
         private
 
         def spawn_worker(task, queue)

lib/redis_client/cluster/concurrent_worker/pooled.rb

@@ -38,6 +38,10 @@ def close
           nil
         end
 
+        def inspect
+          "#<#{self.class.name} tasks: #{@q.size}, workers: #{@size}>"
+        end
+
         private
 
         def setup
@@ -52,13 +56,15 @@ def reset
         end
 
         def ensure_workers
-          @workers.size.times do |i|
+          @size.times do |i|
             @workers[i] = spawn_worker unless @workers[i]&.alive?
           end
         end
 
         def spawn_worker
-          Thread.new(@q) { |q| loop { q.pop.exec } }
+          Thread.new(@q) do |q|
+            loop { q.pop.exec }
+          end
         end
       end
     end