如何等到所有线程完成工作？

Question

我有以下脚本（不要参考内容）：

import _thread

def func1(arg1, arg2):
    print("Write to CLI")

def verify_result():
    func1()


for _ in range (4):
    _thread.start_new_thread(func1, (DUT1_CLI, '0'))

verify_result()

我想同时执行（比如 4 个线程）func1()，在我的例子中它包括一个可能需要时间执行的函数调用。然后，只有在最后一个线程完成其工作后，我才想执行verify_result()。

目前，我得到的结果是所有线程都完成了他们的工作，但是verify_result()在所有线程完成他们的工作之前执行。

我什至尝试在 for 循环下使用以下代码（当然我导入了线程）但没有完成工作（不要参考参数）

t = threading.Thread(target = Enable_WatchDog, args = (URL_List[x], 180, Terminal_List[x], '0'))
t.start()
t.join()

Answer 1

您的最后一个threading示例很接近，但您必须将线程收集在一个列表中，一次启动它们，然后等待它们一次完成。这是一个简化的示例：

import threading
import time

# Lock to serialize console output
output = threading.Lock()

def threadfunc(a,b):
    for i in range(a,b):
        time.sleep(.01) # sleep to make the "work" take longer
        with output:
            print(i)

# Collect the threads
threads = []
for i in range(10,100,10):
    # Create 9 threads counting 10-19, 20-29, ... 90-99.
    thread = threading.Thread(target=threadfunc,args=(i,i+10))
    threads.append(thread)

# Start them all
for thread in threads:
    thread.start()

# Wait for all to complete
for thread in threads:
    thread.join()