diff options
author | ryan <ryan@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-11-29 03:23:11 +0000 |
---|---|---|
committer | ryan <ryan@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-11-29 03:23:11 +0000 |
commit | 81eb635f8cf9e2c25703cb9735dce012daa70ccc (patch) | |
tree | 4102ab5473041741ca442502b2d8231f170c4dca /lib/minitest/parallel_each.rb | |
parent | 304885cdffeba202de0e51425f76d92945a3b2a5 (diff) | |
download | ruby-81eb635f8cf9e2c25703cb9735dce012daa70ccc.tar.gz |
Imported minitest 4.3.2 (r8026)
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@37967 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib/minitest/parallel_each.rb')
-rw-r--r-- | lib/minitest/parallel_each.rb | 36 |
1 files changed, 36 insertions, 0 deletions
diff --git a/lib/minitest/parallel_each.rb b/lib/minitest/parallel_each.rb new file mode 100644 index 0000000000..d501aa34ef --- /dev/null +++ b/lib/minitest/parallel_each.rb @@ -0,0 +1,36 @@ +# encoding: utf-8 +###################################################################### +# This file is imported from the minitest project. +# DO NOT make modifications in this repo. They _will_ be reverted! +# File a patch instead and assign it to Ryan Davis. +###################################################################### + +class ParallelEach + require 'thread' + include Enumerable + + N = (ENV['N'] || 2).to_i + + def initialize list + @queue = Queue.new # *sigh*... the Queue api sucks sooo much... + + list.each { |i| @queue << i } + N.times { @queue << nil } + end + + def grep pattern + self.class.new super + end + + def each + threads = N.times.map { + Thread.new do + Thread.current.abort_on_exception = true + while job = @queue.pop + yield job + end + end + } + threads.map(&:join) + end +end |