在python中并行执行任务

在python中并行执行任务

内置的threading.Thread类提供了您所需要的一切：开始启动一个新线程，并加入以等待线程结束。

import threadingdef task1():    passdef task2():    passdef task3():    passdef task4():    passdef task5():    passdef task6():    passdef dep1():    t1 = threading.Thread(target=task1)    t2 = threading.Thread(target=task2)    t3 = threading.Thread(target=task3)    t1.start()    t2.start()    t3.start()    t1.join()    t2.join()    t3.join()def  dep2():    t4 = threading.Thread(target=task4)    t5 = threading.Thread(target=task5)    t4.start()    t5.start()    t4.join()    t5.join()def dep3():    d1 = threading.Thread(target=dep1)    d2 = threading.Thread(target=dep2)    d1.start()    d2.start()    d1.join()    d2.join()d3 = threading.Thread(target=dep3)d3.start()d3.join()

另外，您可以使用Queue.join等待线程结束。