树莓派4B学习笔记14:Python多线程编程_线程间的同步通信_(锁‘threading.Lock’)

今日继续学习树莓派4B 4G:(Raspberry Pi,简称RPi或RasPi)

 本人所用树莓派4B 装载的系统与版本如下:

 版本可用命令 (lsb_release -a) 查询:

 Opencv 版本是4.5.1:

 今日学习树莓派与Python的多进程编程_线程间同步通信

 文章提供测试代码讲解,整体代码贴出、测试效果图

目录

建立简单的多线程:

创建一个新的线程对象:

 代码示例:

测试效果与解释:

join方法的使用:

线程间的同步与通信:

问题代码与说明:

竞态条件:

使用锁同步对共享资源的访问:

代码改进提示:

网上学习网址贴出:


建立简单的多线程:

创建一个新的线程对象:

threading.Thread 类用于创建一个新的线程对象。

这个类接受几个参数,其中最重要的是 targetargs

target

target 参数是一个可调用的对象(如函数或方法),当线程启动时,这个对象会被线程执行。在这个例子中,target 被设置为 counter 函数,所以新创建的线程会执行 counter 函数。

args

args 参数是一个元组,用于给 target 函数传递参数。在这个例子中,args 是一个只包含一个元素的元组,即字符串 "计数A"。当 t1 线程启动并调用 counter 函数时,它会传递这个字符串作为参数。

需要注意的是,由于 args 需要是一个元组,所以即使只传递一个参数,也需要用逗号 , 来表明它是一个元组(在只有一个元素的元组后面加上逗号是一个常见的约定)。

 代码示例:

以下代码简单示例了如何编写一个简单的多线程程序:

# -*- coding: utf-8 -*-  
import time  
import threading  def counter(name):  for i in range(5):  print(name, i)  time.sleep(1)  t1 = threading.Thread(target=counter, args=("计数A",))  
t2 = threading.Thread(target=counter, args=("计数B",))  t1.start()  
t2.start() print("主线程完成")

测试效果与解释:

我们发现这个程序中一共三条线程:t1、t2、主线程

主线程因为只有一句prtint,因此在t1、t2计数第一次后就结束了

同时:t1、t2俩个线程是一起运行的

join方法的使用:

如果想主线程等待其余线程执行完,则可以使用join方法:

这样主线程就会在俩个子线程结束后才执行:

线程间的同步与通信:

问题代码与说明:

下面展示一段问题代码,该段代码有个全局变量N,程序试图通过多个线程对其进行加操作

从而达到快速加到某个值的效果:

# -*- coding: utf-8 -*-  
import time  
import threading  # 定义一个全局变量,整数类型  
N=0def Add(name):global N                  # 如果想在函数内部修改全局变量的值,需要使用global关键字  for i in range(10000):  N += 1                 # 使用 += 来递增全局变量t1 = threading.Thread(target=Add, args=("累加1",))  
t2 = threading.Thread(target=Add, args=("累加2",))  
t3 = threading.Thread(target=Add, args=("累加3",))  t1.start()  
t2.start() 
t3.start()   t1.join() 
t2.join() 
t3.join()print("主线程完成 N的最终值为:{}".format(N))

虽然我们发现这个操作结果是预期的30000,并未出现更改全局变量 N 冲突的情况,主要是因为线程间对 N 的增加操作是原子的(atomic)。在Python中,对于整数类型(int)和不可变类型(如元组、字符串等),在CPython实现中,简单的赋值和算术操作通常是原子的。

但是,请注意,这种情况并不意味着多线程环境下对全局变量的修改总是安全的。对于更复杂的操作或可变类型(如列表、字典等),多线程访问和修改可能会出现问题,例如数据竞争(data race)、死锁(deadlock)或条件竞争(condition race)。

竞态条件:

在以下给出的网址中的视频内就展示了对全局变量的非原子操作导致的加减输出混乱的情况

多线程编程:一次性搞懂线程同步机制_哔哩哔哩_bilibili

我们发现他的多线程程序并未累加全局变量到预期的值10万,而是运行出了六次不同的结果

使用锁同步对共享资源的访问:

threading.Lock

Lock 对象提供了一种方法来同步线程,以确保在任何时候只有一个线程可以访问共享资源。

下面是修改后的代码,其中添加了 Lock 来保护对全局变量 N 的访问:

# -*- coding: utf-8 -*-    
import time    
import threading    # 定义一个全局变量,整数类型  
N = 0  
# 定义一个全局锁  
lock = threading.Lock()  def Add(name):  global N, lock  for i in range(10000):  # 在修改N之前先获取锁  with lock:  N += 1                 # 使用 += 来递增全局变量  t1 = threading.Thread(target=Add, args=("累加1",))    
t2 = threading.Thread(target=Add, args=("累加2",))    
t3 = threading.Thread(target=Add, args=("累加3",))    t1.start()    
t2.start()   
t3.start()     t1.join()   
t2.join()   
t3.join()  print("主线程完成 N的最终值为:{}".format(N))

添加了一个名为 lockthreading.Lock 对象。

Add 函数中,我使用 with lock: 语句块来确保在修改 N 时锁是获取的。

这个 with 语句块会在进入时自动调用 lock.acquire() 来获取锁,并在退出时自动调用 lock.release() 来释放锁。

这样,在任何时候只有一个线程可以执行 N += 1 这行代码。

现在,即使你运行多个线程来同时修改 N,也不会出现数据不一致的问题,因为每个线程在修改 N 之前都会先获取锁,确保其他线程在此期间不会修改 N

运行效果展示:

代码改进提示:

但频繁地上锁解锁十分浪费资源,可以先定义一个局部变量代为运算,最后赋值给全局:

这样我们只需一次上锁与释放的操作就可以做到目标结果:

修改前繁琐的部分:

会进行高达10000次的:获取锁、释放锁的操作

修改的部分:

只进行了一次获取、释放锁的操作

整体代码:

# -*- coding: utf-8 -*-    
import time    
import threading    # 定义一个全局变量,整数类型  
N = 0  
# 定义一个全局锁  
lock = threading.Lock()  def Add(name):  global N, lockn=0for i in range(10000):  n+=1# 在修改N之前先获取锁  with lock:  N += n                 # 使用 += 来递增全局变量  t1 = threading.Thread(target=Add, args=("累加1",))    
t2 = threading.Thread(target=Add, args=("累加2",))    
t3 = threading.Thread(target=Add, args=("累加3",))    t1.start()
t2.start()
t3.start()t1.join()
t2.join()
t3.join()  print("主线程完成 N的最终值为:{}".format(N))

运行结果:

网上学习网址贴出:

100秒学会Python多线程threading_哔哩哔哩_bilibili

多线程编程:一次性搞懂线程同步机制_哔哩哔哩_bilibili

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

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

相关文章

Hbase面试题总结

一、介绍下HBase架构 --HMaster HBase集群的主节点,负责管理和协调整个集群的操作。它处理元数据和表的分区信息,控制RegionServer的负载均衡和故障恢复。--RegionServer HBase集群中的工作节点,负责存储和处理数据。每个RegionServer管理若…

axios之CancelToken取消请求

从 v0.22.0 开始,Axios 支持以 fetch API 方式—— AbortController 取消请求 此 API 从 v0.22.0 开始已被弃用,不应在新项目中使用 官网链接 1. 背景 最近项目中遇到一个场景,当连续触发一个请求时,如果是同一个接口&#xf…

【Redis-04 补充】Redis事务

【Redis-04 补充】Redis事务 1. 事务冲突的问题1.1 举例1.2 悲观锁1.3 乐观锁1.4 Redis中的乐观锁 WATCH key [key …]1.5 Redis事务三特性 2. 秒杀案例2.1 相关代码2.2 模拟并发工具httpd-tools 3. 设计一个秒杀系统3.1 预热库存3.2 秒杀请求3.3 生成订单3.4 限流与防刷 4. 总…

【代码随想录】【算法训练营】【第52天】 [647]回文子串 [516]最长回文子序列

前言 思路及算法思维,指路 代码随想录。 题目来自 LeetCode。 day 52,周五,开始补作业了~ 题目详情 [647] 回文子串 题目描述 647 回文子串 解题思路 前提:寻找回文子串,子串意味着元素连续 思路:…

JavaScript数据类型转换

目录 任务描述 相关知识 字符串转整数 字符串转小数 数字转字符串 布尔型与其他类型的相互转换 隐式转换 编程要求 任务描述 数据类型转换是开发过程中最常碰到的问题之一。 本关任务:函数mainJs()有三个字符串类型的参数a、b和c,你需要分别把…

Android 10.0 关于定制自适应AdaptiveIconDrawable类型的动态时钟图标的功能实现系列一

1.前言 在10.0的系统rom定制化开发中,在关于定制动态时钟图标中,原系统是不支持动态时钟图标的功能,所以就需要从新 定制动态时钟图标关于自适应AdaptiveIconDrawable类型的样式,就是可以支持当改变系统图标样式变化时,动态时钟 图标的背景图形也跟着改变,所以接下来就来…

jupyter中使用使用事件循环

1、背景 应该在jupyter中遇到过这种问题: “RuntimeError: This event loop is already running”. 这表示,你在jupyter中使用事件循环会出现无法执行,因为他不允许嵌套,所以可以用下面方式解决。 2、方法 By design asyncio …

低代码+定制:优化项目管理的新方案

引言 在当今快速变化的商业环境中,企业需要更加灵活、高效的项目管理工具。低代码平台作为一种新的开发方式,因其能够快速构建应用程序而受到广泛关注。与此同时,软件定制开发仍然是满足特定复杂需求的重要手段。在项目管理中,低代…

【RT摩拳擦掌】基于RT106L/S语音识别的百度云控制系统

【RT摩拳擦掌】基于RT106L/S语音识别的百度云控制系统 一 文档简介二 平台构建2.1 使用平台2.2 百度智能云2.2.1 物联网核心套件2.2.2 在线语音合成 2.3 playback语音数据准备与烧录2.4 开机语音准备与添加2.5 唤醒词识别词命令准备与添加 三 代码准备3.1 sln-local/2-iot 代码…

Caused by SSLError(SSLError(1, ‘[SSL: BAD_ECPOINT] bad ecpoint (_ssl.c:852)‘)

追根溯源: python在访问https请求时,在没有证书的情况下需要设置忽略证书,但有时候证书的忽略会引发其他异常,如: requests.exceptions.SSLError: HTTPSConnectionPool(host127.0.0.1, port443): Max retries exceed…

【开发环境】MacBook M2安装git并拉取gitlab项目,解决gitlab出现Access Token使用无效的方法

文章目录 安装Homebrew安装git打开IDEA配置git打开IDEA拉取项目 安装Homebrew /bin/zsh -c "$(curl -fsSL https://gitee.com/cunkai/HomebrewCN/raw/master/Homebrew.sh)"在iTerm等命令行工具打开后,输入上面的命令 之后根据中文提示完成Homebrew的下载…

使用StringStream处理字符串

使用StringStream处理字符串 大家好,我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编,也是冬天不穿秋裤,天冷也要风度的程序猿!今天我们将深入探讨在Java中如何使用StringStream处理字符串,以及它的应…

高考填报志愿,是选就业前景?还是选自己的兴趣爱好?

一、 当前的就业形式 受yi情影响,全国的就业处于下滑趋势,互联网和实体企业呈现疲软势态,很多企业不得不裁员。大学毕业生人数几乎每年都会上涨,带来的是僧多粥少的就业状态。 考得好不如报得好 就业环境如此严峻的形势下&#…

itext生成pdf文件demo示例

需求 在PDF文件中植入一些信息(pdf模版) 制作模版 可以看到下面红色箭头标注位置,这都是我们需要动态写入数据的表单域,可以使用wps等工具来制作 点击编辑表单,可以给对应空间添加表单域,表单域名称是ke…

网络专线学习

准备工作: https://help.aliyun.com/zh/express-connect/user-guide/before-you-start?spma2c4g.11186623.0.0.593f6746C17guR 专线接入流程 https://help.aliyun.com/zh/express-connect/user-guide/process-of-creating-a-dedicated-physical-connection?spma2c…

Redis 哨兵主备切换的数据丢失问题应该怎么解决?

引言:Redis作为一种高性能的内存数据库,广泛应用于分布式系统中。为了保证服务的高可用性,Redis提供了哨兵(Sentinel)机制,用于监控和管理Redis实例的自动故障恢复。然而,即使在哨兵的保护下&am…

Golang | Leetcode Golang题解之第204题计数质数

题目&#xff1a; 题解&#xff1a; func countPrimes(n int) int {primes : []int{}isPrime : make([]bool, n)for i : range isPrime {isPrime[i] true}for i : 2; i < n; i {if isPrime[i] {primes append(primes, i)}for _, p : range primes {if i*p > n {break}…

idea 项目互联网转内网开发 依赖报错问题 maven问题

场景&#xff1a; 这个问题困扰好久&#xff0c;通过分析后&#xff0c;发现是maven配置问题&#xff0c;废话不多说&#xff0c;上干活。 问题描述 项目互联网从转内网开发&#xff0c;提前下载好repository&#xff0c;跟项目一起导入内网&#xff0c;导入后&#xff0c;发…

行内块元素的幽灵空白问题:揭秘与解决策略

在CSS布局中&#xff0c;行内块元素&#xff08;inline-block&#xff09;的使用可以提供更多的控制和灵活性&#xff0c;但它们也可能带来一些棘手的问题&#xff0c;尤其是所谓的“幽灵空白”问题。本文将探讨这一问题的原因&#xff0c;以及如何通过几种不同的方法来解决它。…

ubuntu 18 虚拟机安装(6) postgresql pg_dump pg_restore

ubuntu 18 虚拟机安装&#xff08;6&#xff09; postgres pg_dump pg_restore postgresql 10.3 下的 pg_dump、pg_restore https://blog.csdn.net/ctypyb2002/article/details/79881745 pg_dump pg_dump dumps a database as a text file or to other formats.Usage:pg_dum…