内置的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等待线程结束。



