From af0497398961b6556cae25c8ddd55327a4ad5104 Mon Sep 17 00:00:00 2001 From: Eric Wong Date: Wed, 16 Dec 2009 23:59:29 -0800 Subject: join_threads method is exclusive to ThreadPool --- lib/rainbows/thread_pool.rb | 8 ++++++++ 1 file changed, 8 insertions(+) (limited to 'lib/rainbows/thread_pool.rb') diff --git a/lib/rainbows/thread_pool.rb b/lib/rainbows/thread_pool.rb index 917b835..3ef719a 100644 --- a/lib/rainbows/thread_pool.rb +++ b/lib/rainbows/thread_pool.rb @@ -67,5 +67,13 @@ module Rainbows end while G.alive end + def join_threads(threads) + G.quit! + threads.delete_if do |thr| + G.tick + thr.alive? ? thr.join(0.01) : true + end until threads.empty? + end + end end -- cgit v1.2.3-24-ge0c7