怎么在初级并发练习中用Queue锁结合文件流的sleep方法实现同步计数

老芳大大_5649

老芳大大_5649

2026-06-05

989人浏览

原创

queue实现同步计数无需手动加锁,因其put/get内置线程安全机制;sleep属time模块,与文件流无关;多线程应通过queue传递数据,由主线程统一写文件以避免竞争。

在初级并发练习中,用 queue 实现同步计数并不需要额外加锁,因为 queue 本身是线程安全的;而“结合文件流的 sleep 方法”这个说法存在概念混淆——sleep 是 time 模块的函数,不属于文件流,文件对象也没有 sleep 方法。你真正想做的,很可能是:用多线程向一个共享计数目标(比如文件)安全写入,同时通过 time.sleep() 模拟耗时操作,并借助 queue.queue 协调任务或传递结果。

为什么不用手动加锁?Queue 已经帮你做了

queue.Queue 的 put() 和 get() 方法内部自带锁机制,天然支持线程安全。如果你只是想让多个线程协作完成计数(例如各自算一部分,最后汇总),直接用 Queue 传递中间结果即可,无需 threading.Lock。

  • 每个线程计算一个子结果(如 +100),然后 q.put(result)
  • 主线程从队列取值并累加,避免竞争条件
  • 相比全局变量 + Lock,代码更清晰、不易出错

如何用 Queue + sleep 模拟带延迟的并发计数

下面是一个典型初级练习示例:启动 3 个线程,每线程 sleep 随机时间后向队列放入自己的计数值(比如 1),主线程等待全部完成并求和:

python-pro
python-pro

高级 Python 特性、异步编程、性能调优、静态类型、内存管理、Python 内部机制及生态库方面的专家。

下载
<font size="2"><pre class="brush:php;toolbar:false;">import time
import threading
import queue
import random
<p>q = queue.Queue()</p><p>def worker(id):
time.sleep(random.uniform(0.1, 0.5))  # 模拟处理延迟
q.put(1)  # 每个线程贡献 1 次计数</p><p>threads = []
for i in range(3):
t = threading.Thread(target=worker, args=(i,))
t.start()
threads.append(t)</p><p>for t in threads:
t.join()  # 等所有线程结束</p><p>total = 0
while not q.empty():
total += q.get()</p><p>print("总计数:", total)  # 输出: 总计数: 3
</p>

如果非要写入文件,Queue 该怎么配合?

若目标是把每次计数“写入文件”,注意:文件写入(f.write())不是原子操作,多线程直接写同一文件会乱序或覆盖。正确做法是——只让主线程负责写文件,其他线程只通过 Queue 发送数据:

  • 工作线程计算完后 q.put((timestamp, value))
  • 主线程循环 q.get(),按顺序写入文件(可加换行或 JSON 格式)
  • 这样既避免了文件竞争,又保留了执行时序信息

常见误区提醒

❌ 不要对 Queue 对象显式加锁(如 with lock: q.put(...))——多余且可能死锁
❌ 不要用 open().write() 在多个线程里直接写同一个文件
❌ 不要依赖 time.sleep() 实现同步逻辑——它只是模拟延迟,不能替代同步机制
✅ 正确姿势:Queue 做线程间安全通信,sleep 做可控延迟,文件 I/O 交由单一线程串行处理

PHP速学视频免费教程(入门到精通)
PHP速学视频免费教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

python

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
java
java

Java是一个通用术语,用于表示Java软件及其组件,包括“Java运行时环境 (JRE)”、“Java虚拟机 (JVM)”以及“插件”。php中文网还为大家带了Java相关下载资源、相关课程以及相关文章等内容,供大家免费下载使用。

2023.06.15

9877

6

java正则表达式语法
java正则表达式语法

java正则表达式语法是一种模式匹配工具,它非常有用,可以在处理文本和字符串时快速地查找、替换、验证和提取特定的模式和数据。本专题提供java正则表达式语法的相关文章、下载和专题,供大家免费下载体验。

2023.07.05

7022

9

java自学难吗
java自学难吗

Java自学并不难。Java语言相对于其他一些编程语言而言,有着较为简洁和易读的语法,本专题为大家提供java自学难吗相关的文章,大家可以免费体验。

2023.07.31

6192

8

java配置jdk环境变量
java配置jdk环境变量

Java是一种广泛使用的高级编程语言,用于开发各种类型的应用程序。为了能够在计算机上正确运行和编译Java代码,需要正确配置Java Development Kit(JDK)环境变量。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.01

1064

3

java保留两位小数
java保留两位小数

Java是一种广泛应用于编程领域的高级编程语言。在Java中,保留两位小数是指在进行数值计算或输出时,限制小数部分只有两位有效数字,并将多余的位数进行四舍五入或截取。php中文网给大家带来了相关的教程以及文章,欢迎大家前来阅读学习。

2023.08.02

888

3

java基本数据类型
java基本数据类型

java基本数据类型有:1、byte;2、short;3、int;4、long;5、float;6、double;7、char;8、boolean。本专题为大家提供java基本数据类型的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

1296

5

java有什么用
java有什么用

java可以开发应用程序、移动应用、Web应用、企业级应用、嵌入式系统等方面。本专题为大家提供java有什么用的相关的文章、下载、课程内容,供大家免费下载体验。

2023.08.02

2589

5

java在线网站
java在线网站

Java在线网站是指提供Java编程学习、实践和交流平台的网络服务。近年来,随着Java语言在软件开发领域的广泛应用,越来越多的人对Java编程感兴趣,并希望能够通过在线网站来学习和提高自己的Java编程技能。php中文网给大家带来了相关的视频、教程以及文章,欢迎大家前来学习阅读和下载。

2023.08.03

19931

3

配置java环境变量
配置java环境变量

配置Java环境变量是为了让操作系统能够识别和使用Java的相关命令和功能。本专题为大家提供配置java环境变量相关文章,帮助大家解决问题。

2023.08.03

1155

8

热门下载

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

精品课程

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