0

0

C++怎么实现一个简单的协程调度器_C++异步编程底层原理剖析

冰火之心

冰火之心

发布时间:2025-12-08 15:57:06

|

349人浏览过

|

来源于php中文网

原创

答案:C++20协程通过co_await、co_yield、co_return实现异步,结合promise_type、handle和awaiter构建状态机;示例中Task封装协程句柄,Scheduler以FIFO队列管理并轮流恢复执行,体现协作式多任务调度机制。

c++怎么实现一个简单的协程调度器_c++异步编程底层原理剖析

协程是现代C++异步编程的重要组成部分,尤其从C++20开始引入了原生的协程支持。实现一个简单的协程调度器,有助于理解其底层运行机制。下面我们一步步剖析如何用C++20实现一个基础但完整的协程调度器,并解释背后的异步原理。

协程的基本概念与C++20语法

在C++20中,协程通过三个关键字支持:co_awaitco_yieldco_return。函数只要包含其中之一,就会被编译器视为协程。

协程的核心结构包括:

  • promise_type:定义协程的行为(如返回值、异常处理)
  • handle:用于控制协程的生命周期和恢复执行
  • awaiter:控制 co_await 的行为(挂起、恢复)

协程不会像普通函数那样“调用即执行”,而是创建后处于暂停状态,需要手动恢复。

立即学习C++免费学习笔记(深入)”;

实现一个简单的调度器

我们设计一个单线程的FIFO调度器,能注册并运行多个协程。

#include iostream>
#include
#include
#include
struct Task {
struct promise_type {
Task get_return_object() {
return Task{std::coroutine_handle::from_promise(*this)};
}
std::suspend_always initial_suspend() { return {}; }
std::suspend_always final_suspend() noexcept { return {}; }
void return_void() {}
void unhandled_exception() {}
};
std::coroutine_handle handle;
~Task() {
if (handle) handle.destroy();
}
Task(const Task&) = delete;
Task& operator=(const Task&) = delete;
Task(Task&& other) : handle(other.handle) {
other.handle = nullptr;
}
};
class Scheduler {
private:
std::queue<:coroutine_handle>> tasks;
public:
void schedule(Task task) {
tasks.push(task.handle);
}
void run() {
while (!tasks.empty()) {
auto handle = tasks.front();
tasks.pop();
if (!handle.done()) {
handle.resume(); // 恢复协程
}
if (!handle.done()) {
tasks.push(handle); // 若未结束,重新入队
} else {
handle.destroy(); // 清理已完成的协程
}
}
}
};

上面的代码定义了一个最简任务类型 Task,它默认挂起初始和结尾状态。调度器使用队列保存待执行的协程句柄,逐个恢复运行。

编写可调度的协程示例

下面是一个模拟异步操作的协程,每执行一次输出后让出控制权。

唱鸭
唱鸭

音乐创作全流程的AI自动作曲工具,集 AI 辅助作词、AI 自动作曲、编曲、混音于一体

下载
Task async_task(Scheduler& sched, int id) {
for (int i = 0; i std::cout co_await std::suspend_always{}; // 主动挂起
}
}
int main() {
Scheduler sched;
sched.schedule(async_task(sched, 1));
sched.schedule(async_task(sched, 2));
sched.schedule(async_task(sched, 3));
sched.run();
return 0;
}

输出结果会交替执行各个任务:

Task 1 step 0
Task 2 step 0
Task 3 step 0
Task 1 step 1
Task 2 step 1
Task 3 step 1
Task 1 step 2
Task 2 step 2
Task 3 step 2

这体现了协作式多任务的特点:每个任务主动让出CPU,调度器轮流唤醒。

底层原理剖析

C++协程的底层依赖于编译器生成的状态机。当协程遇到 co_await,编译器会:

  • 保存当前局部变量到堆上(由 promise_type 管理)
  • 调用 await_ready 判断是否需要挂起
  • 若挂起,则执行 await_suspend(传入 handle),通常在此注册回调或加入调度队列
  • 后续通过 handle.resume() 触发恢复,跳转回上次暂停点继续执行

协程的开销主要在于堆内存分配(除非优化掉)和上下文切换逻辑。但相比线程,它轻量得多,没有内核态切换成本。

调度器的本质就是管理这些 coroutine_handle 的生命周期和执行顺序,可以扩展为支持优先级、定时唤醒、事件驱动等高级特性。

基本上就这些。C++20协程虽然语法复杂,但一旦理解了 handle、promise 和 awaiter 三者的关系,就能构建出灵活高效的异步系统。这个简单调度器是迈向高性能异步框架的第一步。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
if什么意思
if什么意思

if的意思是“如果”的条件。它是一个用于引导条件语句的关键词,用于根据特定条件的真假情况来执行不同的代码块。本专题提供if什么意思的相关文章,供大家免费阅读。

775

2023.08.22

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

94

2023.09.25

c语言const用法
c语言const用法

const是关键字,可以用于声明常量、函数参数中的const修饰符、const修饰函数返回值、const修饰指针。详细介绍:1、声明常量,const关键字可用于声明常量,常量的值在程序运行期间不可修改,常量可以是基本数据类型,如整数、浮点数、字符等,也可是自定义的数据类型;2、函数参数中的const修饰符,const关键字可用于函数的参数中,表示该参数在函数内部不可修改等等。

529

2023.09.20

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

422

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

544

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

73

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

197

2025.08.29

javascriptvoid(o)怎么解决
javascriptvoid(o)怎么解决

javascriptvoid(o)的解决办法:1、检查语法错误;2、确保正确的执行环境;3、检查其他代码的冲突;4、使用事件委托;5、使用其他绑定方式;6、检查外部资源等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

176

2023.11.23

Python 自然语言处理(NLP)基础与实战
Python 自然语言处理(NLP)基础与实战

本专题系统讲解 Python 在自然语言处理(NLP)领域的基础方法与实战应用,涵盖文本预处理(分词、去停用词)、词性标注、命名实体识别、关键词提取、情感分析,以及常用 NLP 库(NLTK、spaCy)的核心用法。通过真实文本案例,帮助学习者掌握 使用 Python 进行文本分析与语言数据处理的完整流程,适用于内容分析、舆情监测与智能文本应用场景。

9

2026.01.27

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
10分钟--Midjourney创作自己的漫画
10分钟--Midjourney创作自己的漫画

共1课时 | 0.1万人学习

Midjourney 关键词系列整合
Midjourney 关键词系列整合

共13课时 | 0.9万人学习

AI绘画教程
AI绘画教程

共2课时 | 0.2万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号