thread_pool: force threads to wakeup on shutdown

We may use a blocking accept() loop if there is
only a single listener.  In that case threads may
not be able to exit if a SIGQUIT is received, so
force them to run when joining.

1 files changed, 6 insertions, 1 deletions

diff --git a/lib/rainbows/thread_pool.rb b/lib/rainbows/thread_pool.rb
index 6fce3c1..f609483 100644
--- a/lib/rainbows/thread_pool.rb
+++ b/lib/rainbows/thread_pool.rb
@@ -70,7 +70,12 @@ module Rainbows
       G.quit!
       threads.delete_if do |thr|
         G.tick
-        thr.alive? ? thr.join(0.01) : true
+        begin
+          thr.run
+          thr.join(0.01)
+        rescue
+          true
+        end
       end until threads.empty?
     end