HoRain云--Rust 并发编程

HoRain 云小助手个人主页⛺️生活的理想就是为了理想的生活!⛳️ 推荐前些天发现了一个超棒的服务器购买网站性价比超高大内存超划算忍不住分享一下给大家。点击跳转到网站。目录⛳️ 推荐线程实例实例实例实例join 方法实例move 强制所有权迁移实例实例消息传递实例安全高效的处理并发是 Rust 诞生的目的之一主要解决的是服务器高负载承受能力。并发concurrent的概念是指程序不同的部分独立执行这与并行parallel的概念容易混淆并行强调的是同时执行。并发往往会造成并行。本章讲述与并发相关的编程概念和细节。线程线程thread是一个程序中独立运行的一个部分。线程不同于进程process的地方是线程是程序以内的概念程序往往是在一个进程中执行的。在有操作系统的环境中进程往往被交替地调度得以执行线程则在进程以内由程序进行调度。由于线程并发很有可能出现并行的情况所以在并行中可能遇到的死锁、延宕错误常出现于含有并发机制的程序。为了解决这些问题很多其它语言如 Java、C#采用特殊的运行时runtime软件来协调资源但这样无疑极大地降低了程序的执行效率。C/C 语言在操作系统的最底层也支持多线程且语言本身以及其编译器不具备侦察和避免并行错误的能力这对于开发者来说压力很大开发者需要花费大量的精力避免发生错误。Rust 不依靠运行时环境这一点像 C/C 一样。但 Rust 在语言本身就设计了包括所有权机制在内的手段来尽可能地把最常见的错误消灭在编译阶段这一点其他语言不具备。但这不意味着我们编程的时候可以不小心迄今为止由于并发造成的问题还没有在公共范围内得到完全解决仍有可能出现错误并发编程时要尽量小心Rust 中通过 std::thread::spawn 函数创建新线程实例use std::thread;use std::time::Duration;fn spawn_function() {for i in 0..5 {println!(spawned thread print {}, i);thread::sleep(Duration::from_millis(1));}}fn main() {thread::spawn(spawn_function);for i in 0..3 {println!(main thread print {}, i);thread::sleep(Duration::from_millis(1));}}运行结果main thread print 0 spawned thread print 0 main thread print 1 spawned thread print 1 main thread print 2 spawned thread print 2这个结果在某些情况下顺序有可能变化但总体上是这样打印出来的。此程序有一个子线程目的是打印 5 行文字主线程打印三行文字但很显然随着主线程的结束spawn 线程也随之结束了并没有完成所有打印。std::thread::spawn 函数的参数是一个无参函数但上述写法不是推荐的写法我们可以使用闭包closures来传递函数作为参数实例use std::thread;use std::time::Duration;fn main() {thread::spawn(|| {for i in 0..5 {println!(spawned thread print {}, i);thread::sleep(Duration::from_millis(1));}});for i in 0..3 {println!(main thread print {}, i);thread::sleep(Duration::from_millis(1));}}闭包是可以保存进变量或作为参数传递给其他函数的匿名函数。闭包相当于 Rust 中的 Lambda 表达式格式如下|参数1, 参数2, ...| - 返回值类型 { // 函数体 }例如实例fn main() {let inc |num: i32| - i32 {num 1};println!(inc(5) {}, inc(5));}运行结果inc(5) 6闭包可以省略类型声明使用 Rust 自动类型判断机制实例fn main() {let inc |num| {num 1};println!(inc(5) {}, inc(5));}结果没有变化。join 方法实例use std::thread;use std::time::Duration;fn main() {let handle thread::spawn(|| {for i in 0..5 {println!(spawned thread print {}, i);thread::sleep(Duration::from_millis(1));}});for i in 0..3 {println!(main thread print {}, i);thread::sleep(Duration::from_millis(1));}handle.join().unwrap();}运行结果main thread print 0 spawned thread print 0 spawned thread print 1 main thread print 1 spawned thread print 2 main thread print 2 spawned thread print 3 spawned thread print 4join 方法可以使子线程运行结束后再停止运行程序。move 强制所有权迁移这是一个经常遇到的情况实例use std::thread;fn main() {let s hello;let handle thread::spawn(|| {println!({}, s);});handle.join().unwrap();}在子线程中尝试使用当前函数的资源这一定是错误的因为所有权机制禁止这种危险情况的产生它将破坏所有权机制销毁资源的一定性。我们可以使用闭包的 move 关键字来处理实例use std::thread;fn main() {let s hello;let handle thread::spawn(move || {println!({}, s);});handle.join().unwrap();}消息传递Rust 中一个实现消息传递并发的主要工具是通道channel通道有两部分组成一个发送者transmitter和一个接收者receiver。std::sync::mpsc 包含了消息传递的方法实例use std::thread;use std::sync::mpsc;fn main() {let (tx, rx) mpsc::channel();thread::spawn(move || {let val String::from(hi);tx.send(val).unwrap();});let received rx.recv().unwrap();println!(Got: {}, received);}运行结果Got: hi子线程获得了主线程的发送者 tx并调用了它的 send 方法发送了一个字符串然后主线程就通过对应的接收者 rx 接收到了。❤️❤️❤️本人水平有限如有纰漏欢迎各位大佬评论批评指正如果觉得这篇文对你有帮助的话也请给个点赞、收藏下吧非常感谢! Stay Hungry Stay Foolish 道阻且长,行则将至,让我们一起加油吧