Python 多线程并行执行详解

import threading
import time
 
def worker(num, wait_time):
    """
    线程工作函数
    :param num: 线程编号
    :param wait_time: 线程运行时间
    """
    print(f"Thread {num} starting...")
    time.sleep(wait_time)  # 模拟耗时操作
    print(f"Thread {num} finished.")
 
def main():
    """
    主函数，创建并启动线程
    """
    threads = []  # 创建线程列表
    for i in range(3):
        # 创建线程对象，传入目标函数和参数
        t = threading.Thread(target=worker, args=(i, i))
        threads.append(t)  # 将线程添加到列表
        t.start()  # 启动线程
 
    for t in threads:
        t.join()  # 等待所有线程完成
 
if __name__ == "__main__":
    main()

这段代码定义了一个工作函数worker和一个主函数main。主函数创建了三个线程，每个线程调用worker函数并传入不同的参数，然后启动线程。主线程等待所有子线程完成后再退出。这个例子展示了如何使用Python的threading模块来执行并行任务。