Python多线程：主线程如何等待所有子线程结束

多线程基础与线程创建

Python通过内置的threading模块支持多线程编程。要启动子线程，需实例化Thread类并指定目标函数（target）及参数（args）。以下代码展示了如何创建多个线程对象，并将它们存入列表以便统一管理：

from time import ctime
import threading
import time

def a():
    print('Program a is running... at ', ctime(), u'.线程名为：', threading.current_thread().name)
    time.sleep(0.2)

def b(x):
    print('Program b('+x+') is running... at ', ctime(), u'.线程名为：', threading.current_thread().name)
    time.sleep(0.1)

if __name__ == '__main__':
    print('Mainthread %s is running...' % threading.current_thread().name)
    thread_list = []
    # 创建400个执行函数a的线程
    for i in range(400):
        t1 = threading.Thread(target=a)
        thread_list.append(t1)
    
    # 创建执行函数b的线程，传入参数
    t2 = threading.Thread(target=b, args=('Python',))
    thread_list.append(t2)
    t3 = threading.Thread(target=b, args=('Java',))
    thread_list.append(t3)

守护线程与启动机制

在启动线程前，可通过setDaemon(True)将线程设置为守护线程。守护线程的特点是：当主线程结束时，守护线程会被强制终止，无论其是否执行完毕。这在某些场景下可避免主线程退出后子线程残留运行，但需注意数据完整性风险。启动线程需调用start()方法，该方法会异步执行目标函数：

    for t in thread_list:
        t.setDaemon(True)  # 设置为守护线程
        t.start()

主线程等待子线程：join方法

若需主线程等待所有子线程执行完毕后再继续或退出，必须使用join()方法。该方法会阻塞当前线程（此处为主线程），直到调用join的子线程结束。以下代码展示了如何遍历线程列表并逐个调用join，确保主线程在打印结束信息前所有子任务已完成：

    for t in thread_list:
        t.join()  # 阻塞主线程，等待子线程结束
    
    print('Mainthread %s ended.' % threading.current_thread().name)

注意事项与常见问题

1. 守护线程的局限性：若子线程执行耗时操作或涉及数据写入，设置为守护线程可能导致数据丢失。生产环境中建议谨慎使用setDaemon(True)，除非明确需要快速退出。
2. 线程数量限制：示例中创建400个线程，实际运行需注意系统资源限制。过多线程可能导致上下文切换开销过大，建议根据CPU核心数调整并发量。
3. 交互模式差异：在Python交互模式或某些Shell环境中，主线程行为可能与编译后脚本不同。例如，交互模式下主线程可能在Python进程退出时才终止，导致子线程输出延迟显示。建议在独立脚本中测试多线程逻辑。

总结

通过threading模块的Thread类、setDaemon()和join()方法，可实现主线程对子线程的精确控制。掌握这些机制有助于编写高效、可靠的并发程序。以上就是Python多线程中主线程等待子线程结束的详细内容，更多关于Python并发编程的资料请关注本站其它相关文章！