协程库项目—协程类模块

2024-03-11 05:12
文章标签 模块 项目 协程库 协程类

本文主要是介绍协程库项目—协程类模块，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

ucontext_t结构体、非对称协程

协程类

ucontext_t结构体

头文件中定义的四个函数（getcontext(), setcontext(), makecontext(), swapcontext()）和两个结构类型（mcontext_t, ucontext_t）在一个进程中实现用户级的线程切换。
其中，mcontext_t类型与机器相关，不透明；ucontext_t结构体至少包含以下几个域：

typedef struct ucontext {struct ucontext *uc_link;sigset_t         uc_sigmask;stack_t          uc_stack;mcontext_t       uc_mcontext;...
} ucontext_t;

当当前上下文运行终止时，系统会恢复uc_link指向的上下文；uc_sigmask为该上下文中的阻塞信号集合；uc_stack为该上下文中使用的栈；uc_mcontext保存的上下文的特定机器表示，包括调用线程的特定寄存器等。

下面是这四个函数的详细介绍：

int getcontext(ucontext_t *ucp);

初始化ucp结构体，将当前的上下文保存到ucp中。

int setcontext(const ucontext_t *ucp);

设置当前的上下文为ucp，setcontext的上下文ucp应该通过getcontext或者makecontext取得。如果调用成功则不返回。如果上下文是通过调用getcontext()取得，程序会继续执行这个调用（从该上下文的状态开始继续执行，即调用getcontext处后接着执行）。如果上下文是通过调用makecontext取得，程序会调用makecontext函数的第二个参数指向的函数，如果func函数返回，则恢复makecontext第一个参数指向的上下文。如果uc_link为NULL，则线程退出。

void makecontext(ucontext_t *ucp, void (*func)(), int argc, ...);

makecontext修改通过getcontext取得的上下文ucp（这意味着调用makecontext前必须先调用getcontext）。然后给该上下文指定一个栈空间ucp->stack，设置后继的上下文ucp->uc_link。当上下文通过setcontext或者swapcontext激活后，执行func函数，argc为func的参数个数，后面是func的参数序列。当func执行返回后，继承的上下文被激活，如果继承上下文为NULL时，线程退出。

int swapcontext(ucontext_t *oucp, ucontext_t *ucp);

保存当前上下文到oucp结构体中，然后激活upc上下文。如果执行成功，getcontext返回0，setcontext和swapcontext不返回；如果执行失败，getcontext,setcontext,swapcontext返回-1，并设置对应的errno。

小结一下：
makecontext：初始化一个ucontext_t,func参数指明了该context的入口函数，argc为入口参数的个数，每个参数的类型必须是int类型。另外在makecontext前，一般需要显示的初始化栈信息以及信号掩码集同时也需要初始化uc_link，以便程序退出上下文后继续执行。
swapcontext：原子操作，该函数的工作是保存当前上下文并将上下文切换到新的上下文运行。
getcontext：将当前的执行上下文保存在cpu中，以便后续恢复上下文
setcontext：将当前程序切换到新的context,在执行正确的情况下该函数直接切换到新的执行状态，不会返回。

⾮对称模型

非对称协程（asymmetric
coroutines）是跟一个特定的调用者绑定的，协程让出CPU时，只能让回给调用者。何为非对称呢？在于协程的调用(call/resume)和返回(return/yield)的地位不对等。程序控制流转移到被调用者协程，而被调用者只能返回最初调用它的协程。
对称协程（symmetric
coroutines）在于协程调用和返回的地位是对等的。启动之后就跟启动之前的协程没有任何关系了。协程的切换操作，一般而言只有一个操作，yield，用于将程序控制流转移给其他的协程。对称协程机制一般需要一个调度器的支持，按一定调度算法去选择yield的目标协程。

这里采用的是非对称模型，
保证⼦协程不能再创建新的协程，即协程不能嵌套调⽤，⼦协程只能与主线程进行切换。注意下图中子协程只能切换回主协程，不能创建新的子协程。
在这里插入图片描述

对于非对称协程，⼦协程和⼦协程切换导致线程主协程跑⻜的关键原因在于，每个线程只有两个线程局部变量⽤于保存当前的协程上下⽂信息。也就是说线程任何时候都最多只能知道两个协程的上下⽂，其中⼀个是当前正在运⾏协程的上下⽂，另⼀个是线程主协程的上下⽂，如果⼦协程和⼦协程切换，那这两个上下⽂都会变成⼦协程的上下⽂，线程主 协程的上下⽂丢失了，程序也就跑⻜了。

简化协程状态

只设置三种协程状态：就绪态、运⾏态和结束态，⼀个协程要么正在运⾏（RUNNING），要么准备运⾏（READY），要运⾏
结束（TERM）。
在这里插入图片描述

协程操作

协程创建操作
创建线程主协程：只需要将协程设置为当前运行协程，协程转为RUNING，获取当前上下文。
创建⽤户协程：则需要额外创建栈空间和绑定协程入口函数

/**
* @brief 线程主协程构造函数
* @attention ⽆参构造函数只⽤于创建线程的第⼀个协程，也就是线程主函数对应的协程，
* 这个协程只能由GetThis()⽅法调⽤，所以定义成私有⽅法
*/
Fiber::Fiber(){SetThis(this);m_state = RUNNING;if (getcontext(&m_ctx)) {Fzk_ASSERT2(false, "getcontext");}++s_fiber_count;m_id = s_fiber_id++; // 协程id从0开始，⽤完加1Fzk_LOG_DEBUG(g_logger) << "Fiber::Fiber() main id = " << m_id;
}/**
* @brief 构造函数，⽤于创建⽤户协程
* @param[] cb 协程⼊⼝函数
* @param[] stacksize 栈⼤⼩
*/
Fiber::Fiber(std::function<void()> cb, size_t stacksize): m_id(s_fiber_id++), m_cb(cb) {++s_fiber_count;m_stacksize = stacksize ? stacksize : g_fiber_stack_size->getValue();m_stack = StackAllocator::Alloc(m_stacksize);if (getcontext(&m_ctx)) {Fzk_ASSERT2(false, "getcontext");}m_ctx.uc_link = nullptr;m_ctx.uc_stack.ss_sp = m_stack;m_ctx.uc_stack.ss_size = m_stacksize;makecontext(&m_ctx, &Fiber::MainFunc, 0);Fzk_LOG_DEBUG(g_logger) << "Fiber::Fiber() id = " << m_id;
}

协程间执行权转换操作

resume：将协程（非TERM、RUNNING状态）设置为当前运行协程，协程转为RUNING，恢复协程运行
yield：将主协程设置为当前运行协程，协程转为READY，让出执⾏权
主要区别：前者将保存线程主协程上下文，并切换运行子协程的上下文；前者将保存子协程上下文，并切换运行主协程的上下文；

/// @brief 恢复协程运行
///恢复该协程的运行。
void Fiber::resume() {Fzk_ASSERT(m_state != TERM && m_state != RUNNING);SetThis(this);m_state = RUNNING;//涉及后面的协程调度，如果协程参与调度器调度，那么应该和调度器的主协程进行swap，而不是线程主协程// if (m_runInScheduler) {//     if (swapcontext(&(Scheduler::GetMainFiber()->m_ctx), &m_ctx)) {//         Fzk_ASSERT2(false, "swapcontext");//     }// } else {//      if (swapcontext(&(t_thread_fiber->m_ctx), &m_ctx)) {//          Fzk_ASSERT2(false, "swapcontext");//      }//  }//发生段错误，已解决，是新创建的子协程未保存其上下文，导致&m_ctx对未初始化对象进行取地址操作if (swapcontext(&(t_thread_fiber->m_ctx), &m_ctx)) {Fzk_ASSERT2(false, "swapcontext");}
}
/// @brief 当前协程让出执⾏权
///当前协程让出执⾏权, 当前协程的状态有两种情况：1、协程函数未执行完，更新为READY; 2、执行完更新为TERM
void Fiber::yield() {/// 协程运行完之后会自动yield一次，用于回到主协程，此时状态已为结束状态Fzk_ASSERT(m_state == RUNNING || m_state == TERM);SetThis(t_thread_fiber.get());if(m_state != TERM) {m_state = READY;}// 如果协程参与调度器调度，那么应该和调度器的主协程进行swap，而不是线程主协程// if(m_runInScheduler) {//     if(swapcontext(&m_ctx, &(Scheduler::GetMainFiber()->m_ctx))) {//         Fzk_ASSERT2(false, "swapcontext");//     }// } else {//      if (swapcontext(&m_ctx, &(t_thread_fiber->m_ctx))) {//          Fzk_ASSERT2(false, "swapcontext");//      }//  }if (swapcontext(&m_ctx, &(t_thread_fiber->m_ctx))) {Fzk_ASSERT2(false, "swapcontext");}
}

后续工作：实现协程调度类

为使得协程类能够通过调度器来运⾏，需要对已实现的协程类进行以下具体操作：

  1. 给协程类增加⼀个bool类型的成员m_runInScheduler，⽤于记录该协程是否通过调度器来运⾏。
  2. 创建协程时，根据协程的身份指定对应的协程类型，具体来说，只有想让调度器调度的协程的 m_runInScheduler值为true，线程主协程和线程调度协程的m_runInScheduler都为false。
  3. resume⼀个协程时，如果如果这个协程的m_runInScheduler值为true，表示这个协程参与调度器调度，那它应该和三个线程局部变量中的调度协程上下⽂进⾏切换，同理，在协程yield时，也应该恢复调度协程的上下⽂，表示从⼦协程切换回调度协程；
  4. 如果协程的m_runInScheduler值为false，表示这个协程不参与调度器调度，那么在resume协程时，直接和线程主协程切换就可以了，yield也⼀样，应该恢复线程主协程的上下⽂。m_runInScheduler值为false的协程。上下⽂切换完全和调度协程⽆关，可以脱离调度器使⽤。

这篇关于协程库项目—协程类模块的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/796749。

相关文章

这15个Vue指令，让你的项目开发爽到爆

这15个Vue指令，让你的项目开发爽到爆

1. V-Hotkey 仓库地址: github.com/Dafrok/v-ho… Demo: 戳这里 https://dafrok.github.io/v-hotkey 安装: npm install --save v-hotkey 这个指令可以给组件绑定一个或多个快捷键。你想要通过按下 Escape 键后隐藏某个组件，按住 Control 和回车键再显示它吗？小菜一碟： <template
阅读更多...
python: 多模块(.py)中全局变量的导入

python: 多模块(.py)中全局变量的导入

文章目录 global关键字可变类型和不可变类型数据的内存地址单模块(单个py文件)的全局变量示例总结 多模块(多个py文件)的全局变量from x import x导入全局变量示例 import x导入全局变量示例 总结 global关键字 global 的作用范围是模块(.py)级别： 当你在一个模块（文件）中使用 global 声明变量时，这个变量只在该模块的全局命名空
阅读更多...
如何用Docker运行Django项目

如何用Docker运行Django项目

本章教程，介绍如何用Docker创建一个Django，并运行能够访问。 一、拉取镜像 这里我们使用python3.11版本的docker镜像 docker pull python:3.11 二、运行容器 这里我们将容器内部的8080端口，映射到宿主机的80端口上。 docker run -itd --name python311 -p
阅读更多...
深入探索协同过滤：从原理到推荐模块案例

深入探索协同过滤：从原理到推荐模块案例

文章目录 前言一、协同过滤1. 基于用户的协同过滤（UserCF）2. 基于物品的协同过滤（ItemCF）3. 相似度计算方法 二、相似度计算方法1. 欧氏距离2. 皮尔逊相关系数3. 杰卡德相似系数4. 余弦相似度 三、推荐模块案例1.基于文章的协同过滤推荐功能2.基于用户的协同过滤推荐功能 前言     在信息过载的时代，推荐系统成为连接用户与内容的桥梁。本文聚焦于
阅读更多...
在cscode中通过maven创建java项目

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目，文件名一般为项目名8 确定
阅读更多...
Vue3项目开发——新闻发布管理系统（六）

Vue3项目开发——新闻发布管理系统（六）

文章目录 八、首页设计开发1、页面设计2、登录访问拦截实现3、用户基本信息显示①封装用户基本信息获取接口②用户基本信息存储③用户基本信息调用④用户基本信息动态渲染 4、退出功能实现①注册点击事件②添加退出功能③数据清理 5、代码下载 八、首页设计开发 登录成功后，系统就进入了首页。接下来，也就进行首页的开发了。 1、页面设计 系统页面主要分为三部分，左侧为系统的菜单栏，右侧
阅读更多...
SpringBoot项目是如何启动

SpringBoot项目是如何启动

启动步骤 概念 运行main方法，初始化SpringApplication 从spring.factories读取listener ApplicationContentInitializer运行run方法读取环境变量，配置信息创建SpringApplication上下文预初始化上下文，将启动类作为配置类进行读取调用 refresh 加载 IOC容器，加载所有的自动配置类，创建容器在这个过程
阅读更多...
Maven创建项目中的groupId, artifactId, 和 version的意思

Maven创建项目中的groupId, artifactId, 和 version的意思

文章目录 groupIdartifactIdversionname groupId 定义：groupId 是 Maven 项目坐标的第一个部分，它通常表示项目的组织或公司的域名反转写法。例如，如果你为公司 example.com 开发软件，groupId 可能是 com.example。作用：groupId 被用来组织和分组相关的 Maven artifacts，这样可以避免
阅读更多...
2. 下载rknn-toolkit2项目

2. 下载rknn-toolkit2项目

官网链接： https://github.com/airockchip/rknn-toolkit2 安装好git：[[1. Git的安装]] 下载项目： git clone https://github.com/airockchip/rknn-toolkit2.git 或者直接去github下载压缩文件，解压即可。
阅读更多...
9.8javaweb项目总结

9.8javaweb项目总结

1.主界面用户信息显示 登录成功后，将用户信息存储在记录在 localStorage中，然后进入界面之前通过js来渲染主界面 存储用户信息 将用户信息渲染在主界面上，并且头像设置跳转，到个人资料界面 这里数据库中还没有设置相关信息 2.模糊查找 检测输入框是否有变更，有的话调用方法，进行查找 发送检测请求，然后接收的时候设置最多显示四个类似的搜索结果
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2