Rust 的 Arc<Mutex<T>> 的用法示例源代码

news/2024/5/19 2:38:54 标签: rust, Arc, Mutex

在 Rust 中,Arc<Mutex<T>> 是一种组合类型,它结合了 Arc(原子引用计数)和 Mutex(互斥锁)。Arc 用于在多个所有者之间共享数据,而 Mutex 用于确保在任意时刻只有一个线程可以访问被保护的数据。这种组合类型在并发编程中非常有用,特别是当你需要在多个线程之间安全地共享和修改数据时。

下面是一个使用 Arc<Mutex<T>> 的简单示例,它演示了如何在多线程环境中安全地共享和修改一个整数值:

rust">use std::sync::{Arc, Mutex};
use std::thread;
use std::random;

fn main() {
    // 创建一个 Arc<Mutex<i32>>,初始值为 0
    let counter = Arc::new(Mutex::new(0));

    // 创建多个线程,每个线程都会增加计数器的值
    let mut threads = Vec::new();
    for _ in 0..10 {
        let counter = counter.clone();
        let thread = thread::spawn(move || {
            // 获取互斥锁,以便安全地访问和修改计数器的值
            let mut num = counter.lock().unwrap();
            // 随机增加计数器的值
            *num += random::thread_rng().gen_range(1..=10);
        });
        threads.push(thread);
    }

    // 等待所有线程完成
    for thread in threads {
        thread.join().unwrap();
    }

    // 打印最终的计数器值
    let final_count = counter.lock().unwrap();
    println!("Final counter value: {}", *final_count);
}

在这个示例中,我们首先创建了一个 Arc<Mutex<i32>>,其中包含一个初始值为 0 的 i32 类型的计数器。然后,我们创建了 10 个线程,每个线程都会获取互斥锁,以便安全地访问和修改计数器的值。每个线程都会随机增加计数器的值。最后,我们等待所有线程完成,并打印最终的计数器值。

请注意,我们在每个线程中使用 counter.clone() 来获取 Arc<Mutex<i32>> 的一个克隆。这是因为 Arc 允许我们创建多个指向同一数据的引用,而 Mutex 则确保在任意时刻只有一个线程可以访问被保护的数据。这种组合使得 Arc<Mutex<T>> 成为 Rust 中处理并发共享数据的一种强大工具。


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

相关文章

Flutter 核心原理 - UI 框架(UI Framework)

Flutter 既能保证很高的开发效率&#xff0c;又能获得很好的性能。 这两年 Flutter 技术热度持续提高&#xff0c;整个 Flutter 生态和社区也发生了翻天覆地的变化。目前Flutter 稳定版发布到了3.0&#xff0c;现在已经支持移动端、Web端和PC端&#xff0c;通过Flutter 开发的…

MyBatis 之四:结果映射和关联映射

结果映射 当查询的 SQL 中&#xff0c;出现了表字段名和实体类属性名不一致情况时&#xff0c;需要指定映射关系 常见方式&#xff1a; 使用 SQL 的 AS 别名方式ResultMap 方式 普通属性映射配置 第一步&#xff1a;编写结果映射 <resultMap id"empMap" type&qu…

GSAP动画学习

GSAP动画学习 一、安装 npm安装 npm install gsap引用&#xff1a; import { gsap } from "gsap";CDN引用 <script src"https://cdn.jsdelivr.net/npm/gsap3.12.5/dist/gsap.min.js"></script>引用&#xff1a; <script>// use a …

Apache Doris 2.1.0 版本发布:开箱盲测性能大幅优化,复杂查询性能提升 100%

亲爱的社区小伙伴们&#xff0c;我们很高兴地向大家宣布&#xff0c;在 3 月 8 日我们引来了 Apache Doris 2.1.0 版本的正式发布&#xff0c;欢迎大家下载使用。 在查询性能方面&#xff0c; 2.1 系列版本我们着重提升了开箱盲测性能&#xff0c;力争不做调优的情况下取得较好…

C++_学习String

1.标准库中的string类 1. 字符串是表示字符序列的类 2. 标准的字符串类提供了对此类对象的支持&#xff0c;其接口类似于标准字符容器的接口&#xff0c;但添加了专门用于操作单字节字符字符串的设计特性 3. string 类是使用 char( 即作为它的字符类型&#xff0c;使用它的默…

如何在群晖用Docker本地搭建Vocechat聊天服务并无公网ip远程交流协作

文章目录 1. 拉取Vocechat2. 运行Vocechat3. 本地局域网访问4. 群晖安装Cpolar5. 配置公网地址6. 公网访问小结 7. 固定公网地址 如何拥有自己的一个聊天软件服务? 本例介绍一个自己本地即可搭建的聊天工具,不仅轻量,占用小,且功能也停强大,它就是Vocechat. Vocechat是一套支持…

scrcpy远程投屏控制Android

下载 下载后解压压缩包scrcpy-win64-v2.4.zip scrcpy连接手机 1. 有线连接 - 手机开启开发者选项&#xff0c;并开启USB调试&#xff0c;连接电脑&#xff0c;华为手机示例解压scrcpy&#xff0c;在scrcpy目录下打开终端&#xff0c;&#xff08;或添加scrcpy路径为环境变…

接口自动化测试:Postman实战教程!

01、接口测试 &#xff08;1&#xff09;服务器端&#xff08;server&#xff09;&#xff1a;在使用别人的服务器上&#xff0c;例如微信APP客户端&#xff0c;服务端在腾讯的服务端上&#xff0c;微信上的账号信息&#xff0c;聊天记录均存储在服务端上&#xff1b;用户A发送…