diff options
| author | William Johnston <will@johnstonclan.net> | 2016-05-24 08:44:03 -0500 |
|---|---|---|
| committer | William Johnston <will@johnstonclan.net> | 2016-05-24 08:44:03 -0500 |
| commit | 2adb18d58681ef3bfc274f603661ce598e849fa7 (patch) | |
| tree | 3aaf0f4192142ea11460e9458040d87c52f0f4cf | |
| parent | dbad52b5b477936b25c2c5605247a9e70a0796cb (diff) | |
| download | bundler-2adb18d58681ef3bfc274f603661ce598e849fa7.tar.gz | |
Clean up worker threads once done with them.
| -rw-r--r-- | lib/bundler/fetcher/compact_index.rb | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/lib/bundler/fetcher/compact_index.rb b/lib/bundler/fetcher/compact_index.rb index 31557be053..f6993b55ed 100644 --- a/lib/bundler/fetcher/compact_index.rb +++ b/lib/bundler/fetcher/compact_index.rb @@ -89,7 +89,10 @@ module Bundler worker_name = "Compact Index (#{display_uri.host})" worker = Bundler::Worker.new(25, worker_name, func) inputs.each {|input| worker.enq(input) } - inputs.map { worker.deq } + res = inputs.map { worker.deq } + worker.stop + + res end end end |