Multi-Processing in Python

Aus Wiki
Wechseln zu: Navigation, Suche
from multiprocessing import Pool

max_processes = 10

def process_track(cdate,track,config):
  ...

pool = Pool(processes=max_processes)
for ctrack in tracks_to_process:
  ret = pool.apply_async(process_track, args=(ctrack[0],ctrack[1],config))
  ret.get()
pool.close()
pool.join()