Multi-Processing in Python

Aus Wiki
Version vom 29. November 2022, 14:29 Uhr von 129.187.36.61 (Diskussion) (Die Seite wurde neu angelegt: „ from multiprocessing import Pool max_processes = 10 def process_track(cdate,track,config): ... pool = Pool(processes=max_processes) for ctrack in…“)
(Unterschied) ← Nächstältere Version | Aktuelle Version (Unterschied) | Nächstjüngere Version → (Unterschied)
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()