Rust 中 Mutex 的用法

在 Rust 中,Mutex(互斥锁)是用于同步并发访问共享资源的机制。Rust 标准库中的 Mutex 结构体位于 std::sync::Mutex 中,它提供了线程安全的数据访问。Mutex 保证了在同一时间只有一个线程可以访问被锁定的数据。

以下是 Mutex 的基本用法:

  1. 创建一个 Mutex 对象:
use std::sync::Mutex;let mutex = Mutex::new(0); // 初始化 Mutex,锁定一个初始值为 0 的数据。
  1. 锁定 Mutex 以访问其内部数据:
let mut guard = mutex.lock().unwrap(); // 锁定 Mutex,unwrap() 用于处理 Result 类型,简化错误处理
*guard += 1; // 通过 MutexGuard 修改内部数据
// 当 MutexGuard 离开作用域时,锁会自动释放
  1. 在多线程环境中使用 Mutex
use std::sync::Mutex;
use std::thread;let counter = Mutex::new(0);
let mut handles = vec![];for _ in 0..10 {let counter = counter.clone(); // 克隆 Mutex 以在多个线程中使用handles.push(thread::spawn(move || {let mut num = counter.lock().unwrap();*num += 1;}));
}// 等待所有线程完成
for handle in handles {handle.join().unwrap();
}let result = counter.lock().unwrap();
println!("Result: {}", *result); // 应该输出 10,但并发错误可能导致小于 10 的结果

注意:

  • 使用 Mutex 时需要注意死锁(deadlock)的情况,确保在获取锁之后总是适时地释放。
  • Mutex::lock() 方法返回一个 Result<MutexGuard<T>, PoisonError<T>>,这是因为如果线程在持有锁时 panic 了,Mutex 会进入“毒化”状态。在这种情况下,其他尝试锁定 Mutex 的线程将会收到一个 PoisonError。通常,你可以使用 unwrap() 来简化错误处理,但在健壮的生产代码中,你可能需要更仔细地处理这种潜在的错误情况。
  • MutexGuard 结构体实现了 DerefDerefMut,因此你可以直接通过它修改被锁定的值。
  • 在多线程环境中,虽然 Mutex 可以保证数据访问的线程安全性,但并不能解决所有并发问题,例如,它不能解决竞态条件(race condition)问题。在上述例子中,由于线程调度的不确定性,最终结果可能小于 10。

如果你想避免由于线程调度导致的竞态条件,可以考虑使用其他同步原语,如 AtomicUsizeBarrierCondvar 等,或者使用消息传递(如使用 mpsc 通道)来避免共享状态。

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

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

相关文章

画图工具之PlantUML插件使用

文章目录 1 PlantUML插件1.1 引言1.2 什么是PlantUML1.3 PlantUML插件1.3.1 IntelliJ IDEA中插件1.3.2 VS Code中插件1.3.3 使用例子 1.4 PlantUML时序图语法1.4.1 声明参与者1.4.2 消息传递1.4.2.1 同步消息1.4.2.2 异步消息1.4.2.3 返回消息1.4.2.4 自调用 1.4.3 生命线&…

比特米盒2代刷入ARMBIAN

概述 因为最近在整家庭NAS&#xff0c;类似魔百盒之类的机顶盒无法内置硬盘&#xff0c;所以将目光盯上了比特米盒、私家云以及和逸云&#xff0c;海鲜市场一番对比下来也就比特米盒&#xff08;CM2-B&#xff09;的性价比最高&#xff0c;而且还支持双盘位&#xff0c;所以采…

【大模型】fineturn Q-wen

github上下载qwen1_5源码 修改finetun.sh 然后在路径qwen1_5/examples/sft下修改finetun.sh, 内容如下 #!/bin/bash export CUDA_DEVICE_MAX_CONNECTIONS1 DIRpwd# Guide: # This script supports distributed training on multi-gpu workers (as well as single-worker trai…

批处理--将指定磁盘根目录所有隐藏的文件(包括文件夹)去除隐藏属性

如下是实现的脚本&#xff1a;-------------------------------------------------- :loopcd / set /p driverName"请输入驱动器盘符&#xff08;例如&#xff1a;C或c&#xff09;&#xff1a;"%driverName%: dir /AH %driverName%: pausefor /f "delims"…

Leetcode刷题2

文章目录 前言寻找两个正序数组的中位数1️⃣ 双指针快速排序2️⃣ 第k小数解法 Z 字形变换1️⃣ 个人解法2️⃣巧妙解法13️⃣巧妙解法2 字符串转换整数 (atoi)1️⃣ 常规方法2️⃣ 作弊方法&#x1f62b; 整数转罗马数字1️⃣ 常规方法&#xff1a;按照给定规则写出判断条件即…

前端面试题日常练-day32 【面试题】

题目 希望这些选择题能够帮助您进行前端面试的准备&#xff0c;答案在文末。 1. 在jQuery中&#xff0c;以下哪个选项用于获取元素的文本内容&#xff1f; a) text() b) html() c) val() d) attr() 2. jQuery中&#xff0c;以下哪个选项用于在元素上添加一个自定义数据属性…

感动心灵的声音——带情绪的AI配音技术在影视和广告领域的应用

近年来&#xff0c;随着人工智能技术的飞速发展&#xff0c;带情绪的AI配音技术作为其中一项重要应用&#xff0c;正逐渐在影视和广告行业展现其独特的魅力和应用价值。传统的配音工作不仅需要具备优秀的嗓音和表演能力&#xff0c;还要求配音演员能够准确捕捉并表达角色的情感…

WSL调用docker

WSL&#xff08;windows subsystem linux&#xff09;是window系统的原生linux子系统&#xff0c;用于代码开发很方便。 希望在wsl里面运行docker&#xff0c;首先要安装docker在WSL中使用&#xff0c;大部分人的第一想法肯定是用以下命令行安装&#xff08;个人不推荐&#x…

java的unsafe

在Java中&#xff0c;sun.misc.Unsafe 是一个强大且危险的类&#xff0c;它提供了一些直接操作内存、对象和线程的底层功能。这个类通常不鼓励普通开发者使用&#xff0c;因为它绕过了Java语言的一些安全性和内存管理机制&#xff0c;可能会导致难以追踪的错误和安全漏洞。 Un…

前端生成二维码

直接img标签显示 npm i use_qrcode npm包地址 <img :src"qrcode" alt"QR Code" /> const txt: any ref(https://baidu.com) const qrcode useQRCode(txt) const qrcodeLogo useQRCode(txt, { logoSrc: https://www.antdv.com/assets/logo.1ef800…

2.go环境配置与开发工具选择

go 环境配置 下载安装包 官网(https://go.dev/dl/) 下载地址(国内)(https://golang.google.cn/dl/) 根据自己的操作系统选择下载即可 下载后安装 记住地址 比如&#xff1a; D:\work\devtool\go 配置系统环境变量 PATH 指向 go 的安装 bin 目录 比如&#xff1a; D:\work…

若依前端vue实现 输入框下拉选择加搜索用户

探索代码以及详细的注解 <template><div><el-select v-model"selectedUserId" filterable placeholder"选择用户" change"handleChange"><el-optionv-for"user in filteredUsers":key"user.userId":l…

集合框框框地架

这一次来介绍一下常用的集合&#xff1a; 首先是两种集合的《家庭系谱图》&#xff1a; 接下来介绍一下集合的种类&#xff1a; Collection Set SetTreeSet&#xff1a;基于红⿊树实现&#xff0c;⽀持有序性操作&#xff0c;例如&#xff1a;根据⼀个范围查找元素的操作。但…

如何使用纯原生的ADO.NET技术进行数据读取

目录 1. 引用命名空间 2. 创建连接字符串 3. 打开数据库连接 4. 执行SQL查询 5. 读取结果集 6. 处理异常和关闭连接 1. 引用命名空间 在代码文件中引用几个关键的System.Data.SqlClient命名空间&#xff0c;这些命名空间包含了用于数据库操作的类。 using System.Data.Sq…

Unity实现TableView

基于Scrollview封装的TableView&#xff0c;实现对视野外的Cell回收利用&#xff0c;减少创建Cell的开销。 核心逻辑如下&#xff1a; /***************************************动态使用cell核心逻辑开始 **************************************///计算所有cell的坐标信息 …

利用java8 的 CompletableFuture 优化 Flink 程序,性能提升 50%

你好&#xff0c;我是 shengjk1&#xff0c;多年大厂经验&#xff0c;努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注&#xff01;你会有如下收益&#xff1a; 了解大厂经验拥有和大厂相匹配的技术等 希望看什么&#xff0c;评论或者私信告诉我&#xff01; 文章目录 一…

flume sink 简介及官方用例

1、HDFS Sink 此sink将事件写入 Hadoop 分布式文件系统 &#xff08;HDFS&#xff09; 中。它目前支持创建文本和序列文件。它支持两种文件类型的压缩。可以根据经过的时间或数据大小或事件数定期滚动文件&#xff08;关闭当前文件并创建一个新文件&#xff09;。它还按事件起…

AI图书推荐:用100个ChatGPT提示词掌握Python编程

《用100个ChatGPT提示词掌握Python编程》&#xff08;ChatGPT:Your Python Coach Mastering the Essentials in 100 Prompts&#xff09; 塞尔吉奥罗哈斯-加莱亚诺&#xff08;Sergio Rojas-Galeano&#xff09;是一位热情的计算机科学家&#xff0c;对人工智能、机器学习、进化…

C++中获取int最大与最小值(补)

上文中&#xff0c;我们学习了C中获取int最大与最小值的两种方法&#xff1a;C库和移位运算&#xff0c;这篇文章将解决在移位运算中遇到的各种报错&#xff0c;并提出一种新的生成int最值的方法 上文链接&#xff1a;http://t.csdnimg.cn/cn7Ad 移位运算取最值常见报错 Dev…

汇编语言(STC89C52)

指令是计算机计算CPU根据人的意图来执行某种操作的命令。一台计算机所执行的全部指令的集合&#xff0c;称为这个CPU的指令系统。而想要使计算机按照人们的要求完成一项工作&#xff0c;就必须让CPU按顺序执行预设的操作&#xff0c;即逐条执行人们编写的指令。这种按照人民要求…