Fork pool - again

Detlef_R · March 25, 2014, 10:10pm

I am trying a different design for creating a fork pool (or worker pool)
for the processing of data in parallel on multiple cores. However, the
inter process communication between the processes is hanging and I
struggle to understand what is causing the blockage - and how to go
about debugging this.

Code and output is here:

gist.github.com

https://gist.github.com/maasha/af4df2d4f0fe9c6211b7

forkpool2.rb

#!/usr/bin/env ruby

require 'pp'

DEBUG = true
CPUS  = 4

module Enumerable
  # Fork each (feach) creates a fork pool with a specified number of processes
  # (_procs_) to iterate over the Enumerable object processing the specified

This file has been truncated. show original

output.txt

# with DEBUG = false

0
2
1
3
8
5
6
7

This file has been truncated. show original

Hints are most welcome!

Cheers,

Martin

himdel · March 26, 2014, 9:03pm

Code now works (gist updated), except for the fact it is suffering from
race conditions. I want the output in order …

M