come recuperare processo dal pool di processi di pitone

Question

voglio creare molti processi, ogni processo viene eseguito 5 secondi dopo che un processo precedente, vale a dire, l'intervallo di tempo tra ogni processo inizia è di 5 secondi, in modo che: run processo 1 attendere 5 secondi processo run 2 attendere 5 secondi processo esecuzione 3 attendere 5 secondi .....

come:

 for i in range(10): 
      p = multiprocessing.Process(target=func) 
      p.start() 
      sleep(5) 
     #after all child process exit 
     do_something() 

ma voglio chiamare fa_qualcosa() dopo tutto il processo di uscita non so come fare la sincronizzazione qui

con una piscina libary pitone, posso avere

pool = multiprocessing.Pool(processes=4) 
    for i in xrange(500): 
      pool.apply_async(func, i) 
    pool.close() 
    pool.join() 
    do_something() 

ma in questo modo, 4 processi verranno eseguiti simultaneamente, non riesco a decidere l'intervallo di tempo tra i processi, è possibile creare un pool di processi e poi prendere ogni processo, qualcosa come

pool = multiprocessing.Pool(processes=4) 
for i in xrange(500): 
    process = pool.fetch_one() 
    process(func, i) 
    time.sleep(5) 
pool.close() 
pool.join() 
do_something() 

ci sono snippet di una libreria o di un codice sorgente che soddisfano le mie esigenze? grazie

Answer 1

solo per mettere insieme i suggerimenti, si potrebbe fare qualcosa di simile:

plist = [] 
for i in range(10): 
    p = multiprocessing.Process(target=func) 
    p.start() 
    plist.append(p) 
    sleep(5) 
for p in plist: 
    p.join() 
do_something() 

Si potrebbe dare un argomento timeout per join() al fine di gestire i processi bloccati; in tal caso dovresti continuare a scorrere l'elenco, rimuovendo i processi terminati finché la lista non è vuota.