【python】多线程(3)queue队列之不同延时时长的参数调用问题

链接1:【python】多线程(笔记)(1)
链接2:【python】多线程(笔记)(2)Queue队列

0.问题描述

两个线程,但是不同延时时长,导致数据输出频率不同,但是又想基于其中的最大频率实时输出数据(比如线程一与线程二均用来描述某个物体的运动,但是线程一每2秒输出数据,线程二每1秒输出数据,输出数据方式为[线程一数据,线程二数据],希望屏幕每1秒打印出该数据),但是队列中,以后进先出队列为例,数据每取出之后队列就少一个数据,这就需要用global全局变量作为中间值。

1.示例代码

两个线程,func1与func2,
func1的参数从0开始每2秒自增一次并输入到中间队列中,
func2每1秒从中间队列取出最新的参数并打印到屏幕上:如果队列不为空,则打印最新参数;如果为空,则打印历史参数

中间队列设为q
则逻辑如下:
在这里插入图片描述示例代码如下所示:
注意代码逻辑顺序,非常重要!!!

import threading
import time
import queueq=queue.LifoQueue()#后进先出队列,队列长度无限制global qqq
global ppp
ppp=-1#线程二的初始值,为了区别这里给ppp赋值-1
qqq=-2#线程一的初始值
#这两个参数赋值为负仅为了鉴别线程是否会被执行
#由于线程一在下面的threads中优先于线程二执行,屏幕上不会打印出-1与-2#线程一
def func1():#func1每2秒自增一次global qqqq1=0for i in range(5):q1=q1+1qqq=q1q.put(qqq)#最新的qqq值写入q队列中print ("线程一q1: %s, %s" %(qqq,time.ctime()))time.sleep(2)#每2秒向q线程中填入新值#线程二
def func2():#func2每1秒向线程中取值#global qqqglobal pppfor i in range(10):if q.qsize()==0:#如果q线程为空,赋历史值qqqqq=pppprint ("线程二q2: %s, %s" %(qqqqq,time.ctime()))else:#如果q线程不为空,赋新值q2=q.get([i])#func2获取q队列数据,因为后进先出,因此获取的都是最新数据ppp=q2print ("线程二q2: %s, %s" %(q2,time.ctime()))time.sleep(1)#每1秒向q线程中取值#定义线程
threads = []
t1 = threading.Thread(target=func1)#这里谁是t1谁先执行
threads.append(t1)
t2 = threading.Thread(target=func2)#这里谁是t2谁后执行
threads.append(t2)#主程序/主线程
if __name__ == '__main__':for t in threads:#按照顺序执行threads的内容t.setDaemon(True)t.start()t.join()#子线程优先print ("qqq %s" %qqq)#查看qqq的最新值print ("all over %s" %time.ctime())#查看结束时刻print("queue size= %s" %queue.Queue.qsize(q))#查看队列大小

输出结果:
在这里插入图片描述只看q1,每两秒自增并输出一次,正确
只看q2,每一秒输出一次,输出的都是q1的最新值,正确

错误情况一:给队列提前赋值

导致队列不为空,影响后续输出
错误代码:(第11行提前给队列赋值)

import threading
import time
import queueq=queue.LifoQueue()#后进先出队列,队列长度无限制global qqq
global ppp
ppp=-1#线程二的初始值为了区别这里给ppp赋值-1
qqq=-2#先给qqq赋值,然后写入队列中否则func2一开始无法获取数据
q.put(qqq)#提前给队列赋值#线程一
def func1():#func1每2秒自增一次global qqqq1=0for i in range(5):q1=q1+1qqq=q1q.put(qqq)#最新的qqq值写入q队列中print ("线程一q1: %s, %s" %(qqq,time.ctime()))time.sleep(2)#每2秒向q线程中填入新值#线程二
def func2():#func2每1秒向线程中取值#global qqqglobal pppfor i in range(10):if q.qsize()==0:#如果q线程为空,赋历史值qqqqq=pppprint ("线程二q2: %s, %s" %(qqqqq,time.ctime()))else:#如果q线程不为空,赋新值q2=q.get([i])#func2获取q队列数据,因为后进先出,因此获取的都是最新数据ppp=q2print ("线程二q2: %s, %s" %(q2,time.ctime()))time.sleep(1)#每1秒向q线程中取值#定义线程
threads = []
t1 = threading.Thread(target=func1)#, args=[qqq])
threads.append(t1)
t2 = threading.Thread(target=func2)#, args=[qqq])
threads.append(t2)#主程序/主线程
if __name__ == '__main__':for t in threads:#按照顺序执行threads的内容t.setDaemon(True)t.start()t.join()#子线程优先print ("qqq %s" %qqq)#查看qqq的最新值print ("all over %s" %time.ctime())#查看结束时刻print("queue size= %s" %queue.Queue.qsize(q))#查看队列大小

错误结果:
在这里插入图片描述由于队列被提前赋值,导致17:43:16秒时队列不为空,队列中最开始被赋值的-2被取出

错误情况二:线程逻辑顺序反了

正确的情况是func1先自增、将参数写入队列,func2再取数
反过来的话,func2先取数,此时若未提前定义队列,可能会引起错误

错误代码:

import threading
import time
import queueq=queue.LifoQueue()#后进先出队列,队列长度无限制global qqq
global ppp
ppp=-1#线程二的初始值为了区别这里给ppp赋值-1
qqq=-2#先给qqq赋值,然后写入队列中否则func2一开始无法获取数据
#q.put(qqq)#先给qqq赋值,然后写入队列中否则func2一开始无法获取数据#线程一
def func1():#func1每2秒自增一次global qqqq1=0for i in range(5):q1=q1+1qqq=q1q.put(qqq)#最新的qqq值写入q队列中print ("线程一q1: %s, %s" %(qqq,time.ctime()))time.sleep(2)#每2秒向q线程中填入新值#线程二
def func2():#func2每1秒向线程中取值#global qqqglobal pppfor i in range(10):if q.qsize()==0:#如果q线程为空,赋历史值qqqqq=pppprint ("线程二q2: %s, %s" %(qqqqq,time.ctime()))else:#如果q线程不为空,赋新值q2=q.get([i])#func2获取q队列数据,因为后进先出,因此获取的都是最新数据ppp=q2print ("线程二q2: %s, %s" %(q2,time.ctime()))time.sleep(1)#每1秒向q线程中取值#定义线程
threads = []
t1 = threading.Thread(target=func2)#, args=[qqq])
threads.append(t1)
t2 = threading.Thread(target=func1)#, args=[qqq])
threads.append(t2)#主程序/主线程
if __name__ == '__main__':for t in threads:#按照顺序执行threads的内容t.setDaemon(True)t.start()t.join()#子线程优先print ("qqq %s" %qqq)#查看qqq的最新值print ("all over %s" %time.ctime())#查看结束时刻print("queue size= %s" %queue.Queue.qsize(q))#查看队列大小

错误结果:线程二先被启动而且输出错误数据
在这里插入图片描述

这里

#定义线程
threads = []
t1 = threading.Thread(target=func2)#, args=[qqq])
threads.append(t1)
t2 = threading.Thread(target=func1)#, args=[qqq])
threads.append(t2)

导致func2先被执行,正确的应该是

#定义线程
threads = []
t1 = threading.Thread(target=func1)#, args=[qqq])
threads.append(t1)
t2 = threading.Thread(target=func2)#, args=[qqq])
threads.append(t2)

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.rhkb.cn/news/338808.html

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

MyBatis框架-开发方式+参数传递+#{}、${}+返回值处理+查询结果封装为对象+resultType

一、开发方式 MyBatis-Dao层Mapper接口化开发 二、注意事项 1、Mapper接口与Mapper.xml映射文件要满足4个对应 (1)Mapper接口的全类名必须与Mapper映射文件中的namespace相同 (2)Mapper接口中的每一个方法名在Mapper映射文件…

961题库 北航计算机 操作系统 附答案 选择题形式

有题目和答案,没有解析,不懂的题问大模型即可,无偿分享。 第1组 习题 计算机系统的组成包括( ) A、程序和数据 B、处理器和内存 C、计算机硬件和计算机软件 D、处理器、存储器和外围设备 财务软件是一种&#xff…

iOS——类与对象底层探索

类和对象的本质 当我们使用OC创建一个testClass类并在main函数创建它的实例对象的时候,OC的底层到底是什么样的呢? 首先,我们要了解OC对象的底层结构,那么我们就得知道:OC本质底层实现转化其实都是C/C代码。 使用下面…

11Linux学习笔记

Linux 实操篇 目录 文章目录 Linux 实操篇1.rtm包(软件)1.1 基本命令1.2 基本格式1.3安装rtm包1.4卸载rtm包 2.apt包2.1 基本命令结构2.2 常用选项2.3常用命令 1.rtm包(软件) 1.1 基本命令 1.2 基本格式 1.3安装rtm包 1.4卸载r…

④单细胞学习-cellchat细胞间通讯

目录 1,原理基础 流程 受体配体概念 方法比较 计算原理 2,数据 3,代码运行 1,原理基础 原文学习Inference and analysis of cell-cell communication using CellChat - PMC (nih.gov) GitHub - sqjin/CellChat: R toolk…

字符串操作java

题目: 描述 给定长度为n的只有小写字母的字符串s,进行m次操作,每次将[l,r]范围内所有c1字符改成c2,输出操作完的字符串 输入描述: 第一行两个数n,m 第二行一个字符串s 之后m行,每行两个数l 、r两个字符…

[DDR5 Jedec 4-1] 预充电命令 Precharge

依公知及经验整理,原创保护,禁止转载。 专栏 《深入理解DDR》 1. 预充电(Precharge)含义 由于SDRAM的寻址具体独占性,因此在进行完读写操作后,若需对同一L-Bank的另一行进行寻址,则必须先关闭原…

针对大模型的上下文注入攻击

大型语言模型(LLMs)的开发和部署取得了显著进展。例如ChatGPT和Llama-2这样的LLMs,利用庞大的数据集和Transformer架构,能够产生连贯性、上下文准确性甚至具有创造性的文本。LLMs最初和本质上是为静态场景设计的,即输入…

idea+tomcat+mysql 从零开始部署Javaweb项目(保姆级别)

文章目录 新建一个项目添加web支持配置tomcat优化tomcat的部署运行tomcatidea数据库连接java连接数据库 新建一个项目 new project;Java;选择jdk的版本;next;next;填写项目名字,选择保存的路径;…

C++进阶之AVL树+模拟实现

目录 目录 一、AVL树的基本概念 1.1 基本概念 二、AVL树的模拟实现 2.1 AVL树节点的定义 2.2 插入操作 2.3 旋转操作 2.4 具体实现 一、AVL树的基本概念 1.1 基本概念 二叉搜索树虽可以缩短查找的效率,但如果数据有序或接近有序二叉搜索树将退化为单支树&…

微信里的东西怎么打印出来呢

随着微信的普及,我们的日常生活和工作都离不开这个强大的社交工具。无论是重要的工作文件、孩子的作业、还是精彩的旅行照片,我们都习惯在微信里保存和分享。但是,当需要将这些微信里的内容打印出来时,很多人可能会感到困惑和麻烦…

【C++】vector的模拟实现

💗个人主页💗 ⭐个人专栏——C学习⭐ 💫点击关注🤩一起学习C语言💯💫 目录 导读 1. vector的核心框架接口 2. 构造函数 2.1 基本构造 2.2 拷贝构造(传统写法) 2.3 析构函数 2…

验证外星语词典

在解决算法题时,哈希表是经常被使用的工具,可以用来记录字符串中字母出现的次数,字符串中字符出现的位置等,这里用到的就是利用哈希表储存字符串中字符出现的的位置。 “外星语”的字母表顺序是不一样的,所以…

SIMBA:单细胞嵌入与特征

目前大多数单细胞分析管道仅限于细胞嵌入,并且严重依赖于聚类,而缺乏显式建模不同特征类型之间相互作用的能力。此外,这些方法适合于特定的任务,因为不同的单细胞问题的表述方式不同。为了解决这些缺点,SIMBA作为一种图…

43.自定义线程池(一)

ThreadPool是线程池,里面是一定数量的线程,是消费者。 BlockingQueue阻塞队列,线程池中的线程会从阻塞队列中去拿任务执行。任务多了线程池处理不过来了,就会到Blocking Queue中排队,等待执行。链表结构,特…

使用python实现超市购物系统(一个小例子)

可以增加其他功能,这里就展示一个小的例子~

Crosslink-NX器件应用连载(11): 图像(数据)远程传输

作者:Hello,Panda 大家下午好,晚上好。这里分享一个Lattice Crosslink-NX器件实现图像或数据(卫星数据、雷达数据、ToF传感器数据等)远程传输的案例(因为所描述的内容颇杂,晒图不好晒&#xff…

【刷题】初探递归算法 —— 消除恐惧

送给大家一句话: 有两种东西, 我对它们的思考越是深沉和持久, 它们在我心灵中唤起的惊奇和敬畏就会日新月异, 不断增长, 这就是我头上的星空和心中的道德定律。 -- 康德 《实践理性批判》 初探递归算法 1 递归算…

我给线程池管理框架hippo4j找bug

1 虚拟机参数不生效 hippo4j的docker启动脚本位于 docker/docker-startup.sh 。从下图可以看到 JAVA_OPT放在了jar包名 hippo4j-server.jar之后,而只有项目参数才放在jar包名之后。 实际上这里JAVA_OPT中包含虚拟机参数,而虚拟机参数要放在jar包名之前…

前端之HTML语言(持续更新)

前端之HTML语言 学习完后端的各种层之后,今天开始学习前端,前端和后端都是一个项目的组成部分。 前端对应得到语言是HTML,HTML最重要的有三块,行为,样式,J结构。行为就是交互,理解为鼠标的点击…