Rust:Mutex 的示例代码

news/2024/5/19 3:58:33 标签: rust, mutex

在Rust中,你可以使用std::sync::Mutex来创建一个互斥锁,从而保护共享资源。下面是一个使用Mutex的简单示例:

rust">use std::sync::Mutex;  
use std::thread;  
use std::time::Duration;  
  
fn main() {  
    // 创建一个包含整数的Mutex  
    let counter = Mutex::new(0);  
  
    // 创建多个线程,每个线程都会尝试增加计数器的值  
    let mut handles = vec![];  
    for _ in 0..10 {  
        let counter = counter.clone();  
        let handle = thread::spawn(move || {  
            // 锁定互斥锁以访问内部的值  
            let mut num = counter.lock().unwrap();  
            *num += 1;  
  
            // 假设这里有一些耗时的操作  
            thread::sleep(Duration::from_millis(1));  
        });  
        handles.push(handle);  
    }  
  
    // 等待所有线程完成  
    for handle in handles {  
        handle.join().unwrap();  
    }  
  
    // 锁定互斥锁以读取最终的计数值  
    let result = counter.lock().unwrap();  
    println!("Final Counter: {}", *result);  
}

在这个示例中,我们创建了一个Mutex,它封装了一个整数0。我们然后创建了10个线程,每个线程都试图增加这个计数器的值。由于我们使用了Mutex,我们可以确保在任何时候只有一个线程能够修改计数器的值。

在每个线程中,我们使用lock()方法来获取Mutex的锁。这会阻塞线程,直到它获得锁。lock()方法返回一个Result<MutexGuard, PoisonError>,其中MutexGuard是一个实现了Deref和DerefMut的RAII(Resource Acquisition Is Initialization)风格的封装器,它会在离开作用域时自动释放锁。PoisonError是当互斥锁被毒化(例如,由于内部的数据被破坏)时返回的错误类型。

我们使用unwrap()来简化错误处理,但在生产代码中,你应该更仔细地处理这些可能的错误。

最后,我们等待所有线程完成,并打印出最终的计数值。

请注意,尽管这个示例展示了如何使用Mutex,但在实际的多线程编程中,如果可能的话,你应该优先考虑使用消息传递(例如通过通道)来避免共享状态,因为这通常会导致更简单的代码和更少的同步问题。然而,在某些情况下,共享状态是不可避免的,这时Mutex就是一个非常有用的工具。


http://www.niftyadmin.cn/n/5418091.html

相关文章

个人商城系统开源(发送手机验证码!)

原文地址&#xff1a;个人商城系统开源&#xff08;发送手机验证码&#xff01;&#xff09; - Pleasure的博客 下面是正文内容&#xff1a; 前言 由于近期实在没有什么话题可写和一些有趣的项目教程可以分享。所以我只能决定将我自己亲手编写的一个迷你迷你商城系统进行开源…

探索1688 API接口:实现商品数据自动化处理

在数字化浪潮的推动下&#xff0c;电子商务领域正经历着前所未有的变革。对于希望在这场变革中保持竞争力的企业而言&#xff0c;能够高效地管理和利用商品数据变得至关重要。阿里巴巴旗下的1688平台提供的API接口&#xff0c;就是一把打开商品数据自动化处理大门的钥匙。 168…

03_Tomcat

文章目录 Tomcat概念自制简易的服务器JavaEE规范Tomcat安装Tomcat启动Tomcat的资源部署直接部署虚拟映射 Tomcat的设置 Tomcat 概念 服务器&#xff1a;两层含义。 软件层面&#xff1a;软件&#xff0c;可以将本地的资源发布到网络中&#xff0c;供网络上面的其他用户来访问…

11.Node.js入门

一.什么是 Node.js Node.js 是一个独立的 JavaScript 运行环境&#xff0c;能独立执行 JS 代码&#xff0c;因为这个特点&#xff0c;它可以用来编写服务器后端的应用程序 Node.js 作用除了编写后端应用程序&#xff0c;也可以对前端代码进行压缩&#xff0c;转译&#xff0c;…

来,聊聊前端框架发展史

文章目录 前言一、阶段1. 早期阶段&#xff1a;原生HTML/CSS/JavaScript2. jQuery时代3. MVC/MVVM框架的兴起4. 现代前端框架与工具链4.1. React Webpack Babel4.1.1. 安装依赖4.1.2. 配置Webpack4.1.3. Babel配置4.1.4. React组件和入口文件4.1.5. 运行开发服务器 4.2. Vue.…

记一次项目所学(中间件等)-动态提醒功能(RocketMQ)

记一次项目所学(中间件等&#xff09;–动态提醒功能&#xff08;RocketMQ&#xff09; 订阅发布模式与观察者模式 RocketMQ&#xff1a;纯java编写的开源消息中间件 高性能低延迟分布式事务 Redis : 高性能缓存工具&#xff0c;数据存储在内存中&#xff0c;读写速度非常快 …

[LeetCode][LCR143]树的子结构判断——递归

题目 LCR 143. 子结构判断 给定两棵二叉树 tree1 和 tree2&#xff0c;判断 tree2 是否以 tree1 的某个节点为根的子树具有相同的结构和节点值。注意&#xff0c;空树不会是以 tree1 的某个节点为根的子树具有相同的结构和节点值。 示例&#xff1a; 输入&#xff1a;tree1 …

Redis精讲

redis持久化 RDB方式 Redis Database Backup file (redis数据备份文件), 也被叫做redis数据快照. 简单来说就是把内存中的所有数据记录到磁盘中. 快照文件称为RDB文件, 默认是保存在当前运行目录. [rootcentos-zyw ~]# docker exec -it redis redis-cli 127.0.0.1:6379> sav…