0

0

Python 如何安全地在多线程环境下累加计数器(不加锁)

冷炫風刃

冷炫風刃

发布时间:2026-01-17 12:47:08

|

410人浏览过

|

来源于php中文网

原创

不依赖传统互斥锁的安全累加方法有五种:一、threading.local实现线程私有计数;二、queue.queue消息传递由单线程汇总;三、semaphore伪原子累加(依赖私有属性);四、multiprocessing.value利用底层原子指令;五、numpy+ctypes/numba调用平台原子原语。

python 如何安全地在多线程环境下累加计数器(不加锁)

如果您在 Python 多线程程序中直接对共享整数变量执行 += 操作,将面临竞态条件导致计数丢失的问题。以下是几种不依赖传统互斥锁(如 threading.Lock)实现安全累加的可行方法:

一、使用 threading.local 实现线程私有计数器

该方法为每个线程分配独立的计数器副本,彻底避免共享冲突,适用于各线程只需维护自身计数值、最终无需全局汇总的场景。

1、导入 threading 模块并创建 local() 实例。

2、在线程函数内部,通过 local 实例的属性访问当前线程专属的计数器变量。

立即学习Python免费学习笔记(深入)”;

3、对该变量执行任意次数的 += 操作,均不会影响其他线程的值。

4、主线程无法直接读取各线程的 local 计数器,如需汇总,须由各线程主动上报结果。

二、使用 queue.Queue 替代共享变量

将累加操作转化为“发送增量指令”的消息传递过程,由单一线程(通常是主线程)顺序消费并更新全局计数器,消除并发写入。

1、初始化一个 threading.Queue 实例用于承载增量值。

2、每个工作线程计算完本地增量后,调用 queue.put(delta) 将数值入队。

3、主线程启动一个专用消费者循环,持续调用 queue.get() 获取增量并累加到全局变量。

4、所有线程完成任务后,向队列发送结束信号(如 None),消费者检测到后退出循环。

三、使用原子操作类型——threading.Semaphore(伪原子累加)

利用信号量的内部计数器作为累加载体,其 acquire()release() 方法底层由 C 实现且具有原子性,可间接达成安全递增。

1、创建初始值为 0 的 threading.Semaphore(0) 实例。

钛投标
钛投标

钛投标 | 全年免费 | 不限字数 | AI标书智写工具

下载

2、每次需“加 1”时,调用 semaphore.release() —— 此操作原子性地使内部计数器加 1。

3、获取当前总和时,需通过反射访问其私有属性 _value(仅限 CPython 实现,不可跨版本依赖)。

4、注意该方式仅支持整数累加,且 _value 属于未公开 API,运行时行为无保障。

四、使用 multiprocessing.Value(配合 threading)

借助 multiprocessing 模块提供的进程共享内存对象,其内部已封装原子操作,可在多线程中安全读写。

1、创建 multiprocessing.Value('i', 0),指定类型码 'i' 表示有符号整型。

2、各线程调用 value.value += 1 时,底层会触发原子的 CPU 指令(如 x86 的 LOCK XADD)。

3、无需显式加锁,所有线程对 value.value 的写入天然串行化。

4、该对象支持 ctypes 支持的所有基础类型,但仅限于数值类共享变量。

五、使用 numpy.ndarray 配合 atomic 操作(需 numba 或 ctypes 辅助)

纯 Python 中 numpy 数组本身不提供原子性,但可通过 ctypes 绑定到共享内存,并调用平台特定的原子指令实现。

1、分配一块 ctypes.c_int32 类型的共享内存区域。

2、使用 numpy.frombuffer() 将其映射为 int32 数组。

3、借助 numba.njit(parallel=True) 或手写 ctypes 函数调用 OS 提供的原子加法(如 Windows 的 InterlockedAdd,Linux 的 __atomic_fetch_add)。

4、此方案绕过 GIL 且性能极高,但要求开发者熟悉底层原子原语及平台差异。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
全局变量怎么定义
全局变量怎么定义

本专题整合了全局变量相关内容,阅读专题下面的文章了解更多详细内容。

89

2025.09.18

python 全局变量
python 全局变量

本专题整合了python中全局变量定义相关教程,阅读专题下面的文章了解更多详细内容。

106

2025.09.18

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

763

2023.08.10

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

376

2025.12.24

java多线程相关教程合集
java多线程相关教程合集

本专题整合了java多线程相关教程,阅读专题下面的文章了解更多详细内容。

27

2026.01.21

C++多线程相关合集
C++多线程相关合集

本专题整合了C++多线程相关教程,阅读专题下面的的文章了解更多详细内容。

28

2026.01.21

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

103

2026.02.06

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

376

2025.12.24

JavaScript浏览器渲染机制与前端性能优化实践
JavaScript浏览器渲染机制与前端性能优化实践

本专题围绕 JavaScript 在浏览器中的执行与渲染机制展开,系统讲解 DOM 构建、CSSOM 解析、重排与重绘原理,以及关键渲染路径优化方法。内容涵盖事件循环机制、异步任务调度、资源加载优化、代码拆分与懒加载等性能优化策略。通过真实前端项目案例,帮助开发者理解浏览器底层工作原理,并掌握提升网页加载速度与交互体验的实用技巧。

46

2026.03.06

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
PostgreSQL 教程
PostgreSQL 教程

共48课时 | 10.3万人学习

Git 教程
Git 教程

共21课时 | 4.1万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号