rust学习(tokio协程分析二)

例子:

我们如果使用new_current_thread来创建tokio的协程运行runtime时,

let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();

发现只有调用rt.block_on(...)才能触发。这里我们分析一下为何在new_current_thread的runtime下无法运行的原因。

代码1

fn testCoroutine4() {thread::spawn(||{let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();let guard1 = rt.enter();println!("trace1", );rt.spawn(doSayHi());println!("trace2", );rt.spawn(doSayHi());println!("trace3", );}).join();
}

这个无法运行的情况是由于执行完最后代码println!("trace3", );之后,线程直接就退出了,没有机会做调用栈切换。

根据代码1的情况,我们考虑是否可以保持线程不退出(如代码2),这样是否可以执行到协程(doSayHi)呢?

代码2:

fn testCoroutine5() {thread::spawn(||{let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();let guard1 = rt.enter();println!("trace1", );rt.spawn(doSayHi());println!("trace2", );rt.spawn(doSayHi());println!("trace3", );thread::sleep(Duration::from_secs(10));}).join();
}

和遗憾,还是没有运行doSayHi,这是为什么呢?因为thread::sleep直接把线程sleep了,协程的调用栈也没有被切换。

我们来看一下可以运行的代码:

代码3:

fn testCoroutine6() {thread::spawn(||{let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();let guard1 = rt.enter();println!("trace1", );let v1 = rt.spawn(doSayHi());println!("trace2", );let v2 = rt.spawn(doSayHi());println!("trace3", );rt.block_on(v1);rt.block_on(v2);}).join();
}

输出:

我们可以看到可以正常打印了。所以我们来想一下协程需要依赖哪些情况才能运行:

1.没有退出的线程

2.有切换调用栈的入口

按照上面的思路,我们是否不用block_on(v1)也能保证协程运行能?其实是可以的,参看

fn testCoroutine4() {thread::spawn(||{let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();let guard1 = rt.enter();println!("trace1", );rt.spawn(doSayHi());println!("trace2", );rt.spawn(doSayHi());println!("trace3", );loop {rt.block_on(async {println!("sleep start", );time::sleep(Duration::from_secs(10)).await;println!("sleep end", );});}}).join();
}

哈哈,可以看到,线程最后启动了一个和之前毫无关系的协程代码,里面只是一个sleep(注意!!这个是tokio的sleep),这个sleep的作用就是满足线程有一个协程切换的入口点。我们运行一下看看结果:

正常运行。不过这个代码只是用来验证我们对协程的认识,不建议正式代码中使用。

总结:

之前用过C语言的libco,它的原理是通过注册了libc的大部分posix的io操作函数,然后通过epoll来实现异步io来实现。例如读取socket的数据,如果没有数据,由于是异步io,所以直接切换到下一个调用栈。这样就实现了简单的协程。rust这块貌似对整个协程做了统一的接口管理?在协程中的sleep等操作一定要调用tokio的接口,否则就会直接造成卡死。哈哈。不过如果是multi_thread的话,实际上也没啥关系,就是直接将协程变成了线程操作,程序应该不会出现卡死。

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

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

相关文章

StartAI0.7版本正式上线啦~

【优化内容】 1、新增图生图功能(V2) 2、新增背景移除功能(V1) 3、新增生成数量设置 4、风格选择-增加搜索、详情功能 5、增加悬浮球设置功能 今天我们来详细介绍一下【图生图】这个功能 可以实现更精准的画面控制,…

理解C#里面的集合有哪些?怎么用,什么是安全集合?

介绍 在C#中,集合是一种用于存储和操作多个元素的数据结构。它们提供了各种操作,如添加、删除、查找等,以及遍历集合中的元素。集合通常根据其实现方式和行为特征进行分类。 集合继承IEnumerable 在C#中,几乎所有的集合类型都实现…

垂直领域大模型搭建训练指南,ChemLLM论文介绍

ChemLLM论文介绍,垂直领域模型搭建训练指南(ChemLLM: A Chemical Large Language Model) 返回论文目录 1.论文简介 论文是上海人工智能实验室的工作,想训练一个化学垂直领域的对话大模型,然而现有的化学数据往往是结构性的,所以…

Nodejs基于vue的个性化服装衣服穿搭搭配系统sprinboot+django+php

本个性化服装搭配系统主要根据用户数据信息,推荐一些适合的搭配穿搭,同时,用户也可自己扫描上传自身衣物以及输入存放位置,搭配后存储到“我的搭配”中,以便下次挑选,既可以节省搭配时间,也方便…

【MySQL】MySQL复合查询--多表查询自连接子查询

文章目录 1.基本查询回顾2.多表查询3.自连接4.子查询 4.1单行子查询4.2多行子查询4.3多列子查询4.4在from子句中使用子查询4.5合并查询 4.5.1 union4.5.2 union all 1.基本查询回顾 表的内容如下: mysql> select * from emp; ----------------------------…

Opencv实战(5)平滑处理与常见函数

平滑处理 Opencv实战: Opencv(1)读取与图像操作 Opencv(2)绘图与图像操作 Opencv(3)详解霍夫变换 Opencv(4)详解轮廓 文章目录 平滑处理1.均值滤波2.方框滤波3.高斯滤波4.中值滤波5.双边滤波 常见函数(1).createTrackbar()(2).SetMouseCallback() 图像的平滑处理是…

[element]element-ui框架下载

⭐作者介绍:大二本科网络工程专业在读,持续学习Java,努力输出优质文章 ⭐作者主页:逐梦苍穹 ⭐如果觉得文章写的不错,欢迎点个关注一键三连😉有写的不好的地方也欢迎指正,一同进步😁…

2024腾讯云服务器优惠价格表又降价了,给同行干emo了

腾讯云优惠活动2024新春采购节活动上线,云服务器价格已经出来了,云服务器61元一年起,配置和价格基本上和上个月没什么变化,但是新增了8888元代金券和会员续费优惠,腾讯云百科txybk.com整理腾讯云最新优惠活动云服务器配…

常用sql语句及其优化

文章目录 介绍常用sql语句1. 数据查询1.1 SELECT 语句1.2 DISTINCT 关键字1.3 WHERE 子句1.4 ORDER BY 子句1.5 LIMIT 关键字 2. 数据更新2.1 INSERT INTO 语句2.2 UPDATE 语句2.3 DELETE FROM 语句 3. 数据管理3.1 CREATE TABLE 语句3.2 ALTER TABLE 语句3.3 DROP TABLE 语句 …

Python进阶学习:Pandas--将一种的数据类型转换为另一种类型(astype())

Python进阶学习:Pandas–将一种的数据类型转换为另一种类型(astype()) 🌈 个人主页:高斯小哥 🔥 高质量专栏:Matplotlib之旅:零基础精通数据可视化、Python基础【高质量合集】、PyTorch零基础入门教程&…

android零基础入门,零基础入门android

工欲行其事,必先利其器 1.B4A B4A是Android的基础版,这是一种可简化编程的Android的应用程序开发工具。这是一个IDE,可以允许开发者使用Basic语言来创建Android移动应用。Basic语言是一种过程化编程语言,因为其简单易学&#xff…

linux系统如何安装nginx

首先下载nginx安装包 wget -c http://nginx.org/download/nginx-1.23.1.tar.gz然后解压安装包 tar -zxvf nginx-1.23.1.tar.gz如果服务器没有wget,可以安装一下,有的话可以跳过 yum install -y wget 然后安装相关依赖 yum install -y gcc-c zlib zl…