在并发程序中,一个常见的问题是如何使程序在所有并发操作完成后终止。下面是一个示例代码,展示了如何使用线程的join()方法来解决这个问题:
import threading
def worker():
print("Worker started")
# 模拟一些工作
for i in range(5):
print("Working...")
print("Worker finished")
# 创建一个线程
t = threading.Thread(target=worker)
# 启动线程
t.start()
# 等待线程完成
t.join()
print("Program terminated")
在上面的示例中,我们定义了一个worker函数,它模拟了一些工作。然后,我们创建了一个线程,并使用worker函数作为线程的目标。接着,我们启动了线程,并使用join()方法等待线程完成。最后,我们打印出"Program terminated"来表示程序的终止。
通过使用join()方法,程序会等待线程完成后再终止。这样可以确保在所有并发操作都完成后程序才会终止。
上一篇:并发程序比顺序程序更快吗?
下一篇:并发程序是否比顺序程序更快?