rust学习(tokio协程分析二)

news2024/9/22 15:50:23

例子:

我们如果使用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.coloradmin.cn/o/1480976.html

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

相关文章

【C++初识】语句

文章目录 1.注释 变量 常量 关键字 标识符命名规则 数据类型 sizeof关键字 数据的输入 运算符2.程序流程结构2.1选择结构2.2循环结构2.21while{循环条件}{循环语句};//满足循环条件,执行循环语句2.22do{循环语句}while{循环条件};//do....whi…

你不可不知的数据安全词汇都在这!

关注公众号,回复关键词 “数据安全”,即可获取报告完整版 随着数字化时代的快速发展,数据安全已成为全球企业和组织面临的一项重大挑战。在这一背景下,我们深感需要有一个统一的、全面的数据安全术语基础,以便行业从业…

c++函数指针 回调函数

目录 函数指针 ​编辑 实例 函数指针作为某个函数的参数 实例 std::function轻松实现回调函数 绑定一个函数 作为回调函数 作为函数入参 函数指针 函数指针是指向函数的指针变量。 通常我们说的指针变量是指向一个整型、字符型或数组等变量,而函数指针是指向…

基于SpringBoot的综合小区管理系统的设计与实现

文章目录 项目介绍主要功能截图:部分代码展示设计总结项目获取方式 🍅 作者主页:超级无敌暴龙战士塔塔开 🍅 简介:Java领域优质创作者🏆、 简历模板、学习资料、面试题库【关注我,都给你】 &…

【前端素材】推荐优质后台管理系统 Greeva平台模板(附源码)

一、需求分析 1、系统定义 后台管理系统是一种用于管理网站、应用程序或系统的管理界面,通常由管理员和工作人员使用。它提供了访问和控制网站或应用程序后台功能的工具和界面,使其能够管理用户、内容、数据和其他各种功能。 2、功能需求 后台管理系…

vulhub中JBoss 5.x/6.x 反序列化漏洞复现(CVE-2017-12149)

该漏洞为 Java反序列化错误类型,存在于 Jboss 的 HttpInvoker 组件中的 ReadOnlyAccessFilter 过滤器中。该过滤器在没有进行任何安全检查的情况下尝试将来自客户端的数据流进行反序列化,从而导致了漏洞。 漏洞复现 利用攻击进行漏洞利用yunxu1/jboss-_…

xsslabs第七关

源码 <!DOCTYPE html><!--STATUS OK--><html> <head> <meta http-equiv"content-type" content"text/html;charsetutf-8"> <script> window.alert function() { confirm("完成的不错&#xff01;"…

DSP软件架构

&#x1f3ac;个人简介&#xff1a;一个全栈工程师的升级之路&#xff01; &#x1f4cb;个人专栏&#xff1a;计算机杂记 &#x1f380;CSDN主页 发狂的小花 &#x1f304;人生秘诀&#xff1a;学习的本质就是极致重复! 目录 一 数字信号处理基本运算 二 DSP软件架构 1 哈…

nginx如何配置命令启动

我安装好nginx后&#xff0c;发现不能使用systemctl start nginx或者systemctl stop nginx来控制启停 解决方法如下 首先要建一个nginx.pid的文件 一般是建在 /var/run/这个路径下面 sudo touch /var/run/nginx.pid 添加权限 sudo chmod 644 /var/run/nginx.pid可以进入到…

136.乐理基础-旋律音程、和声音程、自然音程、变化音程

内存参考于&#xff1a;三分钟音乐社 上一个内容&#xff1a;135.乐理基础-半音是小二度吗&#xff1f;全音是大二度吗&#xff1f;三全音-CSDN博客 上一个内容里练习的答案&#xff1a; 旋律音程 旋律音程指的是音程中两个音&#xff0c;一前一后&#xff0c;有先后顺序依次…

Linux调试器-gdb使用与冯诺依曼体系结构

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言 Linux调试器-gdb使用 1. 背景 2. 开始使用 冯诺依曼体系结构 总结 前言 世上有两种耀眼的光芒&#xff0c;一种是正在升起的太阳&#xff0c;一种是正在努力学…

java009 - Java调试debugger

1、debugger概述 程序的调试工具&#xff0c;用于查看追踪程序的执行流程&#xff0c;也可以调试程序。 2、debugger调试流程 2.1 如何加断点 2.2 如何运行加了断点的程序 在代码区域右键---->debugger执行 2.3 看哪里 看console窗口 2.4 点哪里 点step into(F7)这个箭…

SQL Server 阻止了对组件 ‘Ole Automation Procedures‘ 的 过程‘sys.sp_OACreate‘ 的访问

SQL Server 阻止了对组件 Ole Automation Procedures 的 过程sys.sp_OACreate 的访问&#xff0c;因为此组件已作为此服务器安全配置的一部分而被关闭。系统管理员可以通过使用 sp_configure 启用 Ole Automation Procedures。有关启用 Ole Automation Procedures 的详细信息&a…

数据结构从入门到精通——算法的时间复杂度和空间复杂度

算法的时间复杂度和空间复杂度 前言一、算法效率1.1 如何衡量一个算法的好坏1.2 算法的复杂度 二、时间复杂度2.1 时间复杂度的概念2.2 大O的渐进表示法2.3常见时间复杂度计算举例2.4等差数列计算公式2.5等比数列计算方法 三、空间复杂度四、 常见复杂度对比五、 复杂度的oj练习…

灯塔:HTML笔记

网页由哪些部分组成&#xff1f; *文字 图片 音频 视频 超链接 程序员写的代码是通过浏览器转换成网页的 五大浏览器有哪些&#xff1f; *IE浏览器 *火狐浏览器&#xff08;Firefox&#xff09; *谷歌浏览器&#xff08;Chrome&#xff09; *Safari浏览器 *欧朋浏览器&…

【C++】数组、函数、指针

文章目录 1.数组1.1一维数组1.2二维数组 2.函数3.指针&#xff1a;可以通过指针间接访问内存(指针记录地址&#xff09;3.1 指针的定义和使用3.2 指针所占用空间3.3 空指针和野指针3.4 const修饰指针3.5指针和数组3.6指针和函数3.7练习&#xff08;指针、数组、函数&#xff09…

【Java设计模式】三、

文章目录 0、案例&#xff1a;咖啡屋1、简单工厂模式 静态工厂&#xff08;不属于23种之列&#xff09;2、工厂方法模式3、抽象工厂模式4、建造者模式5、原型设计模式 0、案例&#xff1a;咖啡屋 模拟咖啡店点餐。咖啡有多种&#xff0c;抽象类&#xff0c;子类为各种咖啡。咖…

第四个程序:(a+b)^2+a/c-c^2

&#xff08;ab&#xff09;^2a/c-c^2运算出结果 步骤&#xff1a; 第一步&#xff1a; 建立项目; 第二步&#xff1a;添加部件&#xff0c;连线&#xff0c;完成程序 第三步&#xff1a;运行得出结果 视频&#xff1a; (ab)^2ac-c^2

软考-计算题

1.二维矩阵转换成一维矩阵 2.算术表达式&#xff1a; 3.计算完成项目的最少时间&#xff1a;之前和的max&#xff08;必须之前的所有环节都完成&#xff09; 松弛时间&#xff1a;最晚开始时间-最早开始时间 最早&#xff1a;之前环节都完成的和的max 最晚&#xff1a;总时间…

2024年经典【自动化面试题】附答案

一、请描述一下自动化测试流程&#xff1f; 自动化测试流程一般可以分为以下七步&#xff1a; 编写自动化测试计划&#xff1b; 设计自动化测试用例&#xff1b; 编写自动化测试框架和脚本&#xff1b; 调试并维护脚本&#xff1b; 无人值守测试&#xff1b; 后期脚本维…