@@ -1,10 +1,53 @@ module Peach def peach(n = nil, &b) - peach_run(:each, b, n) + return [] if n == 0 or size == 0 + + result = Array.new(size) + + n ||= $peach_default_threads || size + div = (size/n).ceil + + return [] if div == 0 + + threads = [] + max = size - 1 + offset = 0 + for i in (0..n-1) + threads << Thread.new(offset - div, offset > max ? max : offset) do |lower, upper| + for j in lower..upper + yield(slice(j)) + end + end + offset += div + end + threads.each { |t| t.join } + self end def pmap(n = nil, &b) - peach_run(:map, b, n) + return [] if n == 0 + + n ||= $peach_default_threads || size + div = (size/n).ceil + + return [] if div == 0 + + result = Array.new(size) + + threads = [] + max = size - 1 + offset = div + for i in (0..n-1) + threads << Thread.new(offset - div, offset > max ? max : offset) do |lower, upper| + for j in lower..upper + result[j] = yield(slice(j)) + end + end + offset += div + end + threads.each { |t| t.join } + + result end def pselect(n = nil, &b) lib/peach.rb @@ -1,7 +1,7 @@ Gem::Specification.new do |s| s.name = 'peach' - s.version = '0.2' - s.date = '2009-04-05' + s.version = '0.3' + s.date = '2009-07-14' s.authors = ['Ben Hughes'] s.email = 'ben@pixelmachine.org' s.summary = 'Parallel Each and other parallel things' peach.gemspec 68edd5d72c9bf0ab629c546c33974ca1f9768712 Rob Brit rob.s.brit@gmail.com http://github.com/schleyfox/peach/commit/8d4910dd454ca5ad270d6e2d4fe8ff680c10e226 8d4910dd454ca5ad270d6e2d4fe8ff680c10e226 2009-07-14T06:50:39-07:00 2009-07-14T06:50:39-07:00 Optimizations that reduce memory usage a lot. f731232ea3a19fec05fa0ceb51bf7a9e222f56cd Ben Hughes ben@pixelmachine.org