Sylar_网络框架学习——协程模块(四)
admin
2024-03-28 22:22:14
0

26-29课

协程模块

1) 封装assert

封装了assert.h断言,实现断言后能够打印出函数栈的信息,使用了execinfo.h中backtrace()和backtrace_symbols()两个函数

backtrace():传入申请的存储堆栈信息的内存指针,获取堆栈的大小,返回一共有几层堆栈

backtrace_symbols():传入存储堆栈信息的指针,堆栈层数,返回堆栈信息的字符串

按层数输出字符串即可

//实现两个宏函数,判别x,并输出信息
#define SYLAR_ASSERT(x) \if(!(x)) { \SYLAR_LOG_ERROR(SYLAR_GET_ROOT()) << "ASSERTION: " << #x \<< "\nbacktrace:\n"  \< \SYLAR_LOG_ERROR(SYLAR_GET_ROOT()) << "ASSERTION: " << #x \<< "\n" << w \<< "\nbacktrace:\n"  \<

2) 协程

默认在线程中起的第一个协程为主协程,子协程每次调用完毕后都回到主协程,由主协程发起每次调用

类中包含:ucontext_t结构体,其中uc_link表示上下文下一个调度的协程,uc_stack.ss_sp表示协程栈的内存地址,uc_stack.ss_size表示协程栈的大小

包含协程状态,INIT初始,HOLD挂起,EXEC执行,TERM结束,READY准备,EXCEPT出错,以及协程对应的执行函数

#ifndef __SYLAR_FIBER_H__
#define __SYLAR_FIBER_H__
#include
#include
#include
#include"thread.h"
namespace sylar {
class Fiber : public std::enable_shared_from_this {
public:typedef std::shared_ptr ptr;enum State {INIT,HOLD,EXEC,TERM,READY,EXCEPT};
private:Fiber();
public:Fiber(std::function cb, size_t stacksize = 0);~Fiber();//重置协程函数,并重置状态//INIT TERMvoid reset(std::function cb);//切换到当前协程执行void swapIn();//切换到后台执行void swapOut();uint64_t getId() const { return m_id;}
public://设置当前协程static void SetThis(Fiber* f);//返回当前协程static Fiber::ptr GetThis();//协程切换到后台,并且设置为Ready状态static void YieldToReady();//协程切换到后台,并且设置为Hold状态static void YieldToHold();//总协程数static uint64_t TotalFibers();static void MainFunc();static uint64_t GetFiberId();
private:uint64_t m_id = 0;uint32_t m_stacksize = 0;State m_state = INIT;ucontext_t m_ctx;void* m_stack = nullptr;std::function m_cb;
};
}
#endif

3) 使用

// 需要先GetThis初始化一个main协程,调用私有构造函数,t_threadfiber指向主协程
sylar::Fiber::GetThis();
// 生成协程,绑定执行函数,调用有参构造函数
sylar::Fiber::ptr fiber(new sylar::Fiber(run_in_fiber));
//t_fiber指向当前协程,执行swapcontext(),当前协程开始执行
fiber->swapIn();
//在静态函数YieldToHold()中,通过静态GetThis()函数获得当前运行协程的智能指针,将控制权交出
sylar::Fiber::YieldToHold();
//实际上每个协程与MainFunc()绑定,在其中运行传入的cb(),每次交换控制权会再次回到MainFunc()->cb()中,若MainFunc()->cb()运行完毕,执行MainFunc()的销毁,将当前协程的智能指针计数-1,然后swapout返回主协程
#include"sylar/sylar.h"
sylar::Logger::ptr g_logger = SYLAR_GET_ROOT();
void run_in_fiber() {SYLAR_LOG_INFO(g_logger) << "run_in_fiber begin";					// 2sylar::Fiber::YieldToHold();									  // 交换控制权,返回主协程SYLAR_LOG_INFO(g_logger) << "run_in_fiber end";					    // 4sylar::Fiber::YieldToHold();									  // 交换控制权,返回主协程
}																   // 实际上fiber中的MainFunc运行结束,触发销毁,析构子协程 id:1
void test_fiber() {SYLAR_LOG_INFO(g_logger) << "main begin -1";						// 0{sylar::Fiber::GetThis();									   // 初始化主协程,调用私有构造SYLAR_LOG_INFO(g_logger) << "main begin";						// 1sylar::Fiber::ptr fiber(new sylar::Fiber(run_in_fiber));		  // 创建子协程 id:1fiber->swapIn();											  // 交换控制权,进入子协程SYLAR_LOG_INFO(g_logger) << "main after swapIn";				 // 3fiber->swapIn();											  // 交换控制权,进入子协程SYLAR_LOG_INFO(g_logger) << "main after end";					// 5fiber->swapIn();											  // 交换控制权,进入子协程}SYLAR_LOG_INFO(g_logger) << "main after end2";						 // 6
}																	// 析构主协程
int main() {sylar::Thread::SetName("main");test_fiber();return 0;
}
/*
2022-12-08 12:29:42     68861   main    0       [INFO]  [root]  tests/test_fiber.cpp:15 main begin -1
2022-12-08 12:29:42     68861   main    0       [DEBUG] [system]        sylar/fiber.cpp:50      Fiber::Fiber
2022-12-08 12:29:42     68861   main    0       [INFO]  [root]  tests/test_fiber.cpp:18 main begin
2022-12-08 12:29:42     68861   main    0       [DEBUG] [system]        sylar/fiber.cpp:67      Fiber::Fiber id: 1
2022-12-08 12:29:42     68861   main    1       [INFO]  [root]  tests/test_fiber.cpp:8  run_in_fiber begin
2022-12-08 12:29:42     68861   main    0       [INFO]  [root]  tests/test_fiber.cpp:22 main after swapIn
2022-12-08 12:29:42     68861   main    1       [INFO]  [root]  tests/test_fiber.cpp:10 run_in_fiber end
2022-12-08 12:29:42     68861   main    0       [INFO]  [root]  tests/test_fiber.cpp:24 main after end
2022-12-08 12:29:42     68861   main    0       [DEBUG] [system]        sylar/fiber.cpp:87      Fiber::~Fiber id: 1
2022-12-08 12:29:42     68861   main    0       [INFO]  [root]  tests/test_fiber.cpp:27 main after end2
2022-12-08 12:29:42     68861   main    0       [DEBUG] [system]        sylar/fiber.cpp:87      Fiber::~Fiber id: 0
*/

全部实现可见仓库,欢迎点赞。

相关内容

热门资讯

【MySQL】锁 锁 文章目录锁全局锁表级锁表锁元数据锁(MDL)意向锁AUTO-INC锁...
【内网安全】 隧道搭建穿透上线... 文章目录内网穿透-Ngrok-入门-上线1、服务端配置:2、客户端连接服务端ÿ...
GCN的几种模型复现笔记 引言 本篇笔记紧接上文,主要是上一篇看写了快2w字,再去接入代码感觉有点...
数据分页展示逻辑 import java.util.Arrays;import java.util.List;impo...
Redis为什么选择单线程?R... 目录专栏导读一、Redis版本迭代二、Redis4.0之前为什么一直采用单线程?三、R...
【已解决】ERROR: Cou... 正确指令: pip install pyyaml
关于测试,我发现了哪些新大陆 关于测试 平常也只是听说过一些关于测试的术语,但并没有使用过测试工具。偶然看到编程老师...
Lock 接口解读 前置知识点Synchronized synchronized 是 Java 中的关键字,...
Win7 专业版安装中文包、汉... 参考资料:http://www.metsky.com/archives/350.htm...
3 ROS1通讯编程提高(1) 3 ROS1通讯编程提高3.1 使用VS Code编译ROS13.1.1 VS Code的安装和配置...
大模型未来趋势 大模型是人工智能领域的重要发展趋势之一,未来有着广阔的应用前景和发展空间。以下是大模型未来的趋势和展...
python实战应用讲解-【n... 目录 如何在Python中计算残余的平方和 方法1:使用其Base公式 方法2:使用statsmod...
学习u-boot 需要了解的m... 一、常用函数 1. origin 函数 origin 函数的返回值就是变量来源。使用格式如下...
常用python爬虫库介绍与简... 通用 urllib -网络库(stdlib)。 requests -网络库。 grab – 网络库&...
药品批准文号查询|药融云-中国... 药品批文是国家食品药品监督管理局(NMPA)对药品的审评和批准的证明文件...
【2023-03-22】SRS... 【2023-03-22】SRS推流搭配FFmpeg实现目标检测 说明: 外侧测试使用SRS播放器测...
有限元三角形单元的等效节点力 文章目录前言一、重新复习一下有限元三角形单元的理论1、三角形单元的形函数(Nÿ...
初级算法-哈希表 主要记录算法和数据结构学习笔记,新的一年更上一层楼! 初级算法-哈希表...
进程间通信【Linux】 1. 进程间通信 1.1 什么是进程间通信 在 Linux 系统中,进程间通信...
【Docker】P3 Dock... Docker数据卷、宿主机与挂载数据卷的概念及作用挂载宿主机配置数据卷挂载操作示例一个容器挂载多个目...