Module: TeamEffort

Defined in:
lib/team_effort.rb,
lib/team_effort/version.rb

Constant Summary collapse

VERSION = 
"0.0.2"

Class Method Summary collapse

Class Method Details

.work(enumerable, max_process_count = 4) ⇒ Object 



4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
# File 'lib/team_effort.rb', line 4

def self.work(enumerable, max_process_count = 4)
  pids = []

  enumerable.each do |args|
    if pids.size == max_process_count
      finished_pid = Process.wait
      pids.delete finished_pid
    end

    pids << fork do
      yield args
    end
  end

  while !pids.empty?
    finished_pid = Process.wait
    pids.delete finished_pid
  end
end