Module: ParallelWork

Defined in:: lib/parallel_work.rb,
lib/parallel_work/runner.rb,
lib/parallel_work/message.rb,
lib/parallel_work/version.rb,
lib/parallel_work/messaging.rb,
lib/parallel_work/message/quit.rb,
lib/parallel_work/message/work.rb,
lib/parallel_work/message/ready.rb

Defined Under Namespace

Classes: Message, Messaging, Runner

Constant Summary collapse

VERSION =

"0.0.1"

Class Method Summary collapse

.process(work, workers, &process_block) ⇒ Object

Class Method Details

.process(work, workers, &process_block) ⇒ `Object`

Parameters:

work (#each)



11
12
13

# File 'lib/parallel_work.rb', line 11

def self.process work, workers, &process_block
  Runner.new(work.each, process_block).spawn(workers).close_other_sockets.start
end