Anda harus meletakkan semua kode yang menggunakan multiprocessing, di dalam fungsinya sendiri. Ini menghentikannya meluncurkan kumpulan baru secara rekursif saat multiprosesor mengimpor ulang modul Anda dalam proses terpisah:
def parse_file(filename):
...
def main():
pool = mp.Pool(processes=8)
pool.map(parse_file, ['my_dir/' + filename for filename in os.listdir("my_dir")])
if __name__ == '__main__:
main()
Lihat dokumentasi tentang memastikan modul Anda dapat diimpor , juga saran untuk berjalan di Windows(tm)
