Module: Peach
- Defined in:
- lib/peach.rb
Instance Method Summary collapse
Instance Method Details
#peach(n = nil, &b) ⇒ Object
2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 |
# File 'lib/peach.rb', line 2 def peach(n = nil, &b) 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 |
#pmap(n = nil, &b) ⇒ Object
27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/peach.rb', line 27 def pmap(n = nil, &b) 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 |
#pselect(n = nil, &b) ⇒ Object
53 54 55 |
# File 'lib/peach.rb', line 53 def pselect(n = nil, &b) peach_run(:select, b, n) end |