良许Linux教程网 干货合集 详解Rust 并发编程

详解Rust 并发编程

React是一款颠覆式的前端解决方案,其创新的编程思想以及衍生出来的一些生态圈技术可以说是引领了整个前端的发展。

详解Rust 并发编程

安全高效的处理并发是 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 4

join 方法可以使子线程运行结束后再停止运行程序。

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 接收到了。

以上就是良许教程网为各位朋友分享的Linu系统相关内容。想要了解更多Linux相关知识记得关注公众号“良许Linux”,或扫描下方二维码进行关注,更多干货等着你 !

1ad5ad6eddc451da964a8888a6fd5266d0163210
本文由 良许Linux教程网 发布,可自由转载、引用,但需署名作者且注明文章出处。如转载至微信公众号,请在文末添加作者公众号二维码。
良许

作者: 良许

良许,世界500强企业Linux开发工程师,公众号【良许Linux】的作者,全网拥有超30W粉丝。个人标签:创业者,CSDN学院讲师,副业达人,流量玩家,摄影爱好者。
上一篇
下一篇

发表评论

联系我们

联系我们

公众号:良许Linux

在线咨询: QQ交谈

邮箱: yychuyu@163.com

关注微信
微信扫一扫关注我们

微信扫一扫关注我们

关注微博
返回顶部