多线程可提升I/O密集型任务效率,threading模块为核心工具。1. 用Lock避免数据竞争,with语句确保安全加锁释放;2. 通过target或继承Thread创建线程,灵活适配任务需求;3. 调用start启动线程,join等待完成,daemon=True设守护线程;4. 使用Queue实现线程安全通信,支持生产者-消费者模型。注意GIL限制CPU并发,需合理设计线程数、避免死锁、优先队列通信以保证程序稳定高效。

在Python中使用多线程可以提升I/O密集型任务的执行效率,而threading模块是实现多线程编程的核心工具。掌握一些实用技巧能让线程操作更安全、高效。
1. 合理使用线程锁(Lock)避免数据竞争
多个线程访问共享资源时容易引发数据不一致问题,使用threading.Lock能有效保护临界区。
说明:Lock保证同一时间只有一个线程可以执行被保护的代码段。
建议用法:
立即学习“Python免费学习笔记(深入)”;
- 使用上下文管理器(with语句)自动加锁和释放,避免死锁
- 不要在持有锁时执行耗时操作或调用外部函数
import threadinglock = threading.Lock() counter = 0
def increment(): global counter with lock: counter += 1 # 安全修改共享变量
2. 使用Thread类继承或target参数灵活创建线程
创建线程有两种常用方式:通过target指定函数,或继承threading.Thread类。
适用场景:
- 简单任务直接用 target=function 方式更简洁
- 需要封装状态和行为时,推荐继承 Thread 类
def worker(name):
print(f"线程 {name} 正在运行")
t = threading.Thread(target=worker, args=("A",))
t.start()
t.join() # 等待线程结束
示例 - 继承Thread:
BJXShop网上购物系统是一个高效、稳定、安全的电子商店销售平台,经过近三年市场的考验,在中国网购系统中属领先水平;完善的订单管理、销售统计系统;网站模版可DIY、亦可导入导出;会员、商品种类和价格均实现无限等级;管理员权限可细分;整合了多种在线支付接口;强有力搜索引擎支持... 程序更新:此版本是伴江行官方商业版程序,已经终止销售,现于免费给大家使用。比其以前的免费版功能增加了:1,整合了论坛
class MyThread(threading.Thread):
def run(self):
print(f"{self.name} 执行中")
t = MyThread()
t.start()
3. 控制线程生命周期:start、join 和守护线程
理解线程的启动与等待机制对程序稳定性很重要。
关键点:
- 必须调用 start() 启动线程,直接调用 run() 会在主线程中执行
- 使用 join() 可以阻塞主线程直到子线程完成
- 设置 daemon=True 可让子线程随主线程退出而自动结束
t = threading.Thread(target=worker, daemon=True) t.start() # 主线程结束时,t会自动终止
4. 使用Queue进行线程间安全通信
queue.Queue是线程安全的队列,适合在多线程间传递数据。
优势:
- 无需手动加锁,内部已实现同步机制
- 支持阻塞式读取,便于实现生产者-消费者模型
from queue import Queueq = Queue()
def producer(): for i in range(5): q.put(i)
def consumer(): while True: item = q.get() if item is None: break print(f"消费: {item}") q.task_done()
启动线程...
基本上就这些。threading模块功能强大,但要注意GIL限制了CPU密集型任务的并发效果。合理设计线程数量、避免死锁、优先使用队列通信,才能写出稳定高效的多线程程序。










