writer_thread_spawn: factor out Client.quit

Self-documenting code is easier to follow

2 files changed, 11 insertions, 6 deletions

diff --git a/lib/rainbows/writer_thread_spawn.rb b/lib/rainbows/writer_thread_spawn.rb
index a11e82c..0e7d1a7 100644
--- a/lib/rainbows/writer_thread_spawn.rb
+++ b/lib/rainbows/writer_thread_spawn.rb
@@ -32,12 +32,8 @@ module Rainbows::WriterThreadSpawn
 
   def worker_loop(worker)  # :nodoc:
     Client.const_set(:MAX, worker_connections)
-    super(worker) # accept loop from Unicorn
-    Client::CUR.delete_if do |t,q|
-      q << nil
-      G.tick
-      t.alive? ? t.join(0.01) : true
-    end until Client::CUR.empty?
+    super # accept loop from Unicorn
+    Client.quit
   end
   # :startdoc:
 end
diff --git a/lib/rainbows/writer_thread_spawn/client.rb b/lib/rainbows/writer_thread_spawn/client.rb
index 4341b9a..f9c373e 100644
--- a/lib/rainbows/writer_thread_spawn/client.rb
+++ b/lib/rainbows/writer_thread_spawn/client.rb
@@ -7,6 +7,15 @@ class Rainbows::WriterThreadSpawn::Client < Struct.new(:to_io, :q, :thr)
 
   CUR = {} # :nodoc:
 
+  def self.quit
+    g = Rainbows::G
+    CUR.delete_if do |t,q|
+      q << nil
+      g.tick
+      t.alive? ? t.join(0.01) : true
+    end until CUR.empty?
+  end
+
   def queue_writer
     # not using Thread.pass here because that spins the CPU during
     # I/O wait and will eat cycles from other worker processes.