赞
踩
- import threading
- import time
-
- def program1():
- # 程序1的逻辑
- print("程序1开始运行")
- time.sleep(2) # 模拟程序1的执行时间
- print("程序1运行结束")
-
- def program2():
- # 程序2的逻辑
- print("程序2开始运行")
- time.sleep(2) # 模拟程序2的执行时间
- print("程序2运行结束")
-
- # 创建线程对象并并发执行两个程序
- thread1 = threading.Thread(target=program1)
- thread2 = threading.Thread(target=program2)
-
- # 启动线程
- thread1.start()
- thread2.start()
-
- # 等待线程执行完毕
- thread1.join()
- thread2.join()
-
- print("两个程序都已运行完毕")
在上面的示例中,我们创建了两个函数program1()
和program2()
,分别代表两个要并发运行的程序。然后,使用threading.Thread
创建两个线程对象,分别指定要运行的函数。接下来,调用线程对象的start()
方法启动线程。最后,使用join()
方法等待线程执行完毕。
运行上述代码时,程序1开始运行
和程序2开始运行
会同时打印出来,两个程序将并发执行。在本例中,每个程序的逻辑执行时间为2秒。最后,当两个线程都完成后,打印出两个程序都已运行完毕
。
请注意,多线程并发执行可能会导致共享资源的并发访问问题,因此在编写并发程序时要注意线程安全性和同步机制,以避免竞态条件(Race Condition)等问题。
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。