Dear all,<br><br><br>I have a problem with multiprocessing module usage with python2.6.1<br>Here Pool object is to be instantiated with 50 processes  and the method 'run' has to be called with pool object.<br>My actual requirement is to reuse the 50 processes for further processing until 100 items.<br>
<br>#########################<br>import multiprocessing as mp<br><br>def add(a,b):<br>    return a+b<br><br><br>if __name__ == '__main__':<br>    p = mp.Pool(processes=50)<br>    y = 40<br>    for x in  range(100):<br>
        p.apply_async(run, (x, y) )<br>##########################<br>The problem now is that it creates only 32 processes (and not more) and exits with processing first 32 numbers  from range(100) . <br>Is there a cap on the number of subprocesses one can fork ? <br>
Even then,  once these 32 processes r free, I would like to reuse them with next 32 inputs (x) from  range(100 ) in that order.<br>how could i accomplish this ? <br><br>thanks in advance.<br>KM<br><br><br>