I am trying to implement parallel processing with os.fork.. However i want to collect results from each process.. I thought i could use Queues, but i cant seem to get it work. Threading, can not work for me, because of the way some functions have been written -<div>
<br></div><div>Below is a copy of what i had written..</div><div><br></div><div>cheers</div><div><br></div><div>Jojo</div><div><br></div><div>---------------------------------</div><div>import os, time, Queue</div><div>import do_something</div>
<div><br></div><div><br></div><div>mylist1 = [item1, item2, item3 ......]</div><div>mylist2 = [item1,item2, item2 ......]</div><div><br></div><div>def child(x, y):</div><div>    return do_something(x,y)</div><meta charset="utf-8"><div>
<br></div><div>def parent(myqueue):</div><div>    for x, y in zip (mylist1, mylist2):</div><div>         </div><div>         pid = os.fork()</div><div><br></div><div>         if pid !=0:</div><div>              print &#39;Process %d spwaned&#39; %pid</div>
<div>         else:</div><div>             result = child(x, y)</div><div>             sys.exit(0)</div><div>         myqueue.put(result)</div><div>    return myqueue</div><div><br></div><div><br></div><div><br></div><div>
myqueue = Queue.Queue(0)</div><div>data = parent(myqueue)</div><div> </div><meta charset="utf-8"><div>---------------------------</div>