Rust 基于 await、async 的异步编程和纤程、协程的实现

一、Rust 的异步编程

Rust 通过 await、async 实现了其他语言中纤程、协程的机制。下面是一个使用asyncawait的Rust示例代码。这个示例展示了如何异步地读取文件内容。

首先,确保你的Cargo.toml文件包含了tokio库的依赖,如下:

[dependencies]
tokio = { version = "1", features = ["full", "sync"] }

然后,你可以编写如下代码:

use tokio::fs;
use tokio::io;
use tokio::runtime;// 定义一个异步函数,用于读取文件内容
async fn read_file_content(path: &str) -> Result<String, Box<dyn std::error::Error>> {// 使用tokio的fs模块异步读取文件let file = fs::File::open(path).await?;let mut content = String::new();// 使用tokio的io模块异步读取文件内容到字符串中io::read_to_string(file, &mut content).await?;Ok(content)
}#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {let file_path = "example.txt"; // 替换为你的文件路径let content = await!(read_file_content(file_path))?; // 使用await!宏等待异步操作完成println!("File content: {}", content);// 或者使用更现代的await语法let content2 = await read_file_content(file_path)?;println!("File content (using modern await syntax): {}", content2);Ok(())
}

在这个例子中,read_file_content函数是一个异步函数,它使用tokio::fs::File::open异步地打开文件,并使用tokio::io::read_to_string异步地将文件内容读取到字符串中。main函数也是一个异步函数,它使用tokio::main宏来启动一个Tokio运行时,并调用read_file_content函数来异步读取文件内容。在main函数中,你可以看到两种使用await的方式:一种是使用await!宏(这在Tokio的旧版本中常见),另一种是直接使用await关键字(这是推荐的方式,并在Rust和Tokio的新版本中更常见)。

要运行这段代码,请确保你的项目目录中存在一个名为example.txt的文件,或者将file_path变量更改为指向实际存在的文件。然后,使用cargo buildcargo run命令来构建和运行你的程序。

请注意,异步编程在Rust中是一个相对高级的主题,需要一些时间来熟悉。此外,Tokio库可能会随着版本的更新而有所变化,因此建议查阅最新的Tokio文档以获取最准确的信息。

二、await 的意思是要阻塞等到它修饰的函数结束吗?

await 在 Rust 的异步编程中并不是阻塞等待修饰的函数结束。相反,await 允许程序在等待异步操作完成时,释放当前任务的执行权,以便调度器可以执行其他任务。这是非阻塞的,因此不会浪费任何计算资源。

具体来说,当一个 async 函数中遇到一个 await 表达式时,它会暂停当前函数的执行,并返回一个 Future 对象给调度器。调度器随后可以安排其他任务执行,而不会阻塞当前线程。一旦等待的异步操作完成(例如,I/O 操作完成或某个定时器到期),await 表达式的结果就会变得可用,并且 async 函数可以继续执行。

这种机制使得 Rust 的异步编程模型非常高效,能够充分利用系统资源,处理大量的并发任务。因此,await 并不会阻塞线程或整个程序,而是允许程序在等待异步操作时继续执行其他任务。

这里是一个简单的例子来进一步说明 await 的非阻塞特性:

use tokio::runtime;
use tokio::time;async fn say_hello_after(delay: u64) {println!("Waiting for {} seconds...", delay);time::sleep(time::Duration::from_secs(delay)).await; // 非阻塞等待println!("Hello after {} seconds!", delay);
}#[tokio::main]
async fn main() {// 启动两个并发任务,它们都会等待一段时间然后打印消息let task1 = tokio::spawn(say_hello_after(2));let task2 = tokio::spawn(say_hello_after(1));// 等待两个任务完成await!(task1);await!(task2);
}

在这个例子中,say_hello_after 函数是一个异步函数,它等待指定的秒数后打印一条消息。tokio::spawn 用于在Tokio运行时中启动新的并发任务。由于 time::sleep(...).await 是非阻塞的,所以即使 say_hello_after(2) 的延迟比 say_hello_after(1) 长,Tokio运行时仍然能够同时处理这两个任务,并在它们各自的延迟结束后打印相应的消息。

总结来说,await 使得异步编程更加直观和易于管理,同时保持了非阻塞的特性,使得程序能够高效地处理并发任务。

三、async 函数会启用一个新的线程吗?

在Rust的异步编程模型中,async函数本身并不会直接启动一个新的线程。相反,async函数定义了一个可以在未来某个时间点执行的异步计算。这个异步计算可以在当前的线程或执行器(如Tokio运行时)上调度,而不会阻塞该线程的其他工作。

Rust的异步编程是基于事件循环和协程(或称为纤程)的概念,而不是基于线程。这意味着异步函数在执行时,它们的状态会被保存起来,并在需要时恢复执行,而不会占用整个线程。这使得异步函数能够高效地处理I/O操作和其他潜在的阻塞操作,而不会浪费系统资源。

当你调用一个async函数时,它会立即返回一个Future对象,而不是立即执行函数体中的代码。这个Future对象代表了异步操作的结果,并且可以在未来的某个时间点通过await表达式来获取。

Tokio等运行时库负责调度和执行这些异步操作。它们使用非阻塞I/O和事件循环来管理多个异步任务的执行,并根据需要在线程池上调度这些任务。这意味着虽然异步操作本身不会启动新线程,但它们可以在现有的线程池中的线程上执行,从而实现高效的并发处理。

总结来说,async函数本身不会启动新的线程,而是定义了一个可以异步执行的计算。异步操作的执行是由运行时库(如Tokio)管理的,它们可能会在线程池中的线程上调度这些操作,以实现高效的并发处理。

四、异步编程必须借助 Tokio 代码库吗?

async 和 await 不是 Tokio 专门提供的功能,而是 Rust 语言本身的一部分,用于支持异步编程。Tokio 是一个 Rust 中的异步编程库,它提供了一系列用于构建高效并发和异步系统的工具和抽象。在 Tokio 中,你可以使用 async 和 await 关键字来编写异步函数和处理异步操作。

async 关键字用于声明一个函数是异步的,这意味着该函数可以包含挂起执行的操作(如网络请求或文件读写),而不会阻塞整个程序的执行。await 关键字则用于在异步函数中等待一个异步操作完成。

Tokio 库提供了一套完整的异步编程原语和工具,包括异步 I/O、定时器、并发执行等。它使得在 Rust 中编写异步代码变得更加简单和直观,通过结合 async/await 语法,你可以编写出清晰易读的异步代码,提高程序的并发性能和响应能力。

因此,虽然 async 和 await 不是 Tokio 特有的功能,但 Tokio 充分利用了这些关键字,为你提供了一个强大而灵活的异步编程框架。

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

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

相关文章

python汽车租赁系统的设计与实现flask-django-php-nodejs

困扰公司的许多问题当中,汽车租赁管理一定是公司不敢忽视的一块。但是管理好汽车租赁又面临很多麻烦需要解决,例如有几个方面:第一,公司往往汽车数量都比较多,如何保证能够管理到每一汽车;第二,如何在工作琐碎,记录繁多的情况下将汽车租赁的当前情况反应给公司领导相关部门决策…

Python之Web开发中级教程----ubuntu中下载安装Postman

Python之Web开发中级教程----ubuntu中下载安装Postman PostMan 是一款功能强大的网页调试与发送网页 HTTP 请求的 Chrome 插件&#xff0c;可以直接去对我们写出来的路由和视图函数进行调试&#xff0c;作为后端程序员是必须要知道的一个工具。 查看ubuntu系统中是否已经安装了…

零基础学华为ip认证难吗?华为认证费用多少?

零基础学华为ip认证难吗&#xff1f; 首先&#xff0c;零基础的学习者可以通过系统的学习&#xff0c;逐步掌握网络基础知识和技能。可以通过阅读教材、参加培训课程、进行实践操作等方式&#xff0c;不断提升自己的知识和技能水平。同时&#xff0c;学习者还可以利用华为提供的…

常用小知识点总结

1. pc可以跑通&#xff0c;但是安卓编译死循环&#xff0c;可能是函数声明了返回类型&#xff0c;但是没有真正返回 2. ubuntu下根据关键词杀死所有相关进程。ps -ef | grep code | grep -v grep | cut -c 10-16 | xargs kill -s 9 top和ps基本作用都是显示系统进程状况&…

Aloudata 倾力打造,《Data Fabric 白皮书 2.0》正式发布

数字经济时代&#xff0c;越来越多企业开始寻求全新的数据管理范式&#xff0c;以更有效地管理、利用不断增长的数据资产。在此背景下&#xff0c;Data Fabric 的概念应运而生&#xff0c;被视为面向未来的数据管理解决方案。 距离第一版白皮书问世已经过去一年多时间&#xff…

matplotlib绘图一例

网上外卖用户规模及使用率import matplotlib.pyplot as plt import matplotlib.dates as mdates import pandas as pd# 数据源自www.cnnic.net.cn。 l [["2015/12", "1.14亿", "16.5%"], ["2016/6", "1.50亿", "21.1%…

electron-builder 打包问题,下载慢解决方案

目录 问题说明设置下载源 &#xff1f;解决方案思路下载Electron下载winCodeSign下载nsis下载nsis-resources 总结 问题说明 项目使用了Electron&#xff0c;在第一次打包时会遇见下载慢&#xff0c;导致打包进度几乎停滞不前&#xff0c;甚至可能直接报错 其实这是因为Electr…

套的-流量分析

目录 1、流量分析2、寻找flag3、总结 1、流量分析 把流量包下载下来进行分析&#xff0c;得到下面这些信息 通过追踪HTTP流&#xff0c;我们可以很明显的感觉到是对42.193.4.49进行目录爆破 追踪流给出的信息是不完整的&#xff0c;我们只是用来推测大概的过程&#xff0c;了解…

在电脑桌面上怎么制作可视化工作计划待办清单?

对于忙碌的上班族来说&#xff0c;每天都需要处理大量的工作任务&#xff0c;如何在繁杂的工作中保持高效和有序&#xff0c;成为了一个亟待解决的问题。在电脑桌面上制作可视化的工作计划待办清单&#xff0c;就是一个非常实用的方法。通过将工作任务以清单的形式展现在桌面上…

头条网盘拉新怎么通过授权解锁推广权限

头条网盘拉新项目是去年12月份才首发上线的一个项目&#xff0c;从佣金上&#xff0c;只要拉新一个用户就可以获取价格为9元的佣金&#xff0c;且拉失活用户也可以获取价格为4元的佣金&#xff0c;从背景上&#xff0c;背靠字节跳动这个大公司&#xff0c;预算充足&#xff0c;…

2.Labview字符串与路径精讲(上) — 理论篇

本章讲解labview中的字符串和路径及其使用方法&#xff0c;从前面板字符串属性到后面板字符串函数应用做出详细概述&#xff0c;通过本文的学习希望大家了解到字符串在labview编程中的重要地位。 本系列文章为labview 从基础到强化到精通的学习文章&#xff0c;大家可以随时点进…

本地项目文件夹创建python文件并配置conda环境的完整流程

1 在Pycharm中创建新项目 位置就是本地的项目文件夹 2 接着打开pycharm的终端 创建conda环境&#xff08;这个过程需要保证conda.exe能够被系统路径识别&#xff09; conda create --name my_environment&#xff08;my_environment取自己想要的环境名字&#xff09; 还可以指…

MySQL - 单表访问

单表访问 查询方式 MySQL查询的执行方式大致分为下边两种&#xff1a; 使用全表扫描进行查询 这种执行方式很好理解&#xff0c;就是把表的每一行记录都扫一遍嘛&#xff0c;把符合搜索条件的记录加入到结果集就完了。不管是啥查询都可以使用这种方式执行&#xff0c;当然&am…

依赖的多个 jar 中包含了相同类,编译提示 :app:checkDebugDuplicateClasses‘

问题描述 项目依赖了两个 jar 包&#xff0c;并且两个jar 包中包含了路径和名称完全相同的类。编译时报错:app:checkDebugDuplicateClasses‘ 问题分析 大思路就是排除掉 面向 CSDN 编程&#xff0c;网上各种 exclude 方式无效。 面向 Github Copilot 编程&#xff0c; 问&a…

【Machine Learning】Suitable Learning Rate in Machine Learning

一、The cases of different learning rates: In the gradient descent algorithm model: is the learning rate of the demand, how to determine the learning rate, and what impact does it have if it is too large or too small? We will analyze it through the follow…

索引常见面试题

面试中&#xff0c;MySQL 索引相关的问题基本都是一系列问题&#xff0c;都是先从索引的基本原理&#xff0c;再到索引的使用场景&#xff0c;比如&#xff1a; 索引底层使用了什么数据结构和算法&#xff1f;为什么 MySQL InnoDB 选择 Btree 作为索引的数据结构&#xff1f;什…

ProtoBuf-gRPC实践

目录介绍 01.gRPC学习背景 1.1 为什么要学RPC1.2 RPC是什么1.3 网络库收益分析1.4 学习计划说明1.5 学习问题思考 02.ProtoBuf的介绍 2.1 ProtoBuf是什么2.2 ProtoBuf和json2.3 ProtoBuf问题思考2.4 ProtoBuf特点2.5 ProtoBuf存储格式2.6 ProtoBuf优缺点2.7 创建proto文件2.8 …

Oracle等待事件-db file scattered read

上一篇说了下 Oracle等待事件-db file sequential read-CSDN博客 &#xff0c;这一篇说一下它的”孪生兄弟” 另外一个IO 等待事件 db file scattered read(数据库文件分散读) 如果 Oracle 在 SGA 的缓冲区缓存中没有用户请求的数据&#xff0c;则服务器进程会将相应的数据块…

前端学习之css选择器--基本选择器、关系选择器、属性选择器、复合选择器、伪类选择器

目录 基本选择器 结果 关系选择器 结果 父子关系 祖先后代关系 相邻兄弟关系 兄弟关系 ​编辑 属性选择器 结果 复合选择器 结果 伪类选择器 结果 伪类选择器-操作标签 结果 未访问 访问后 悬停 伪类选择器-操作表单 结果 伪类选择器-操作结构 结果 基本选择…

二叉树详解

二叉树详解 一:什么是树1:概念2:树的特点##3:树的一些重要概念 二:二叉树1:二叉树的概念2:二叉树的特点3:特殊的二叉树: 三:二叉树的性质四:二叉树的存储 一:什么是树 1:概念 树是一种非线性的数据结构,它是由n个节点组成的一个具有层次关系的集合,把它叫做树的原因是因为它看…