c++ 协程调度器实现 c++如何编写一个简单的coroutine scheduler

千静酱_7862

千静酱_7862

2026-03-22

998人浏览

原创

std::coroutine_handle不能直接用于调度,因为它仅是协程状态的指针,不包含唤醒、排队、线程绑定或异常处理等调度逻辑;裸调resume()易因生命周期错误、栈销毁或并发问题导致崩溃。

c++ 协程调度器实现 c++如何编写一个简单的coroutine scheduler

为什么不能直接用 std::coroutine_handle 自己调度

因为 std::coroutine_handle 只是协程状态的“指针”,不带调度逻辑——它不负责唤醒、排队、线程绑定或异常传播。你调用 resume() 时,如果此时协程正被其他线程挂起、或栈已销毁、或调度器没准备好,就会崩(常见报错:segmentation fault 或 pure virtual method called)。真实调度必须自己管生命周期、就绪队列和执行上下文。

实操建议:

C++14
C++14

C++14 对 C++11 的修正与增强版本,适合旧系统维护和较老工具链兼容。

下载
  • 所有 coroutine_handle 必须在 resume 前检查 done() == false,否则 resume 已结束协程会 UB
  • 不要把 coroutine_handle 存在栈上然后跨 await 点使用;容易悬垂
  • 调度器启动后,应确保每个 resume 都发生在同一线程(单线程调度器)或加锁/无锁队列(多线程),不能裸调 resume()

最简可行调度器:单线程 + 就绪队列 + run() 循环

不需要线程池、IO 多路复用、优先级——先让 co_await 能跑起来。核心就是两个东西:一个 std::queue<coroutine_handle>></coroutine_handle> 存待执行协程,一个 run() 方法不断 pop + resume。

实操建议:

  • 就绪队列用 std::deque 比 std::queue 更稳,避免某些 STL 实现中 move 构造导致 handle 失效
  • run() 循环里每次 resume 前要检查 handle 是否有效,可用 if (h) h.resume();
  • 协程首次 resume 应由调度器触发(比如从 spawn() 推入队列),不要靠用户手动调 handle.resume()
  • 示例片段:
    void spawn(coroutine_handle h) { ready_queue.push(h); }<br>void run() { while (!ready_queue.empty()) { auto h = ready_queue.front(); ready_queue.pop(); h.resume(); } }

await_suspend 怎么把协程交给调度器

这是协程挂起时的“注册点”。你写的 awaiter 在 await_suspend 里拿到 coroutine_handle,然后扔给调度器的就绪队列或延时队列。关键不是“怎么挂起”,而是“挂起后谁来 resume 它”。

实操建议:

  • 返回 void:表示你已自行安排 resume(比如推入调度器),协程立刻挂起
  • 返回 bool:true 表示已安排,false 表示不挂起(继续执行)——别乱返回 false,容易逻辑跳过
  • 别在 await_suspend 里直接调 resume(),这会破坏挂起语义,导致栈溢出或死循环
  • 如果调度器是全局单例,这里可以直接调 g_scheduler.spawn(h);如果是 per-task 的,需把调度器指针存进 promise_type

promise_type 里必须重载哪些函数

决定协程怎么创建、怎么销毁、挂起失败怎么办。最小集是三个:get_return_object()、initial_suspend()、final_suspend()。少一个都可能 crash 或内存泄漏。

实操建议:

  • get_return_object() 必须返回一个包装了 coroutine_handle 的对象(比如 task<t></t>),且该对象能访问 promise(通常用 handle.from_promise(*this))
  • initial_suspend() 返回 suspend_always{},否则协程一创建就执行,调度器来不及接管
  • final_suspend() 必须返回 suspend_always{},否则协程结束时自动销毁 handle,而你的调度器可能还持有它(use-after-free)
  • 务必实现 unhandled_exception(),至少 std::terminate(),否则协程里抛异常会静默崩溃
调度器最难的不是代码量,是 promise 和 handle 生命周期的对齐——promise 分配在哪(栈?堆?)、谁 delete、resume 后 promise 是否还有效、多个线程同时操作队列是否安全。这些地方一松动,core dump 就在下一行。

C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!

相关文章

c++速学教程(入门到精通)
c++速学教程(入门到精通)

c++怎么学习?c++怎么入门?c++在哪学?c++怎么学才快?不用担心,这里为大家提供了c++速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

c++

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
C++ 智能指针与现代内存管理
C++ 智能指针与现代内存管理

深入讲解 C++ 现代内存管理的核心工具——智能指针,涵盖 unique_ptr 独占所有权语义、shared_ptr 引用计数机制与循环引用问题、weak_ptr 弱引用的应用场景、make_unique/make_shared 工厂函数的性能优势、自定义删除器的编写、RAII 资源管理思想的实践,以及从裸指针迁移到智能指针的重构策略,帮助开发者编写安全无泄漏的现代 C++ 代码。

2026.04.23

359

31

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

2023.07.18

6087

5

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

2023.08.10

2588

6

线程和进程的区别
线程和进程的区别

线程和进程的区别:线程是进程的一部分,用于实现并发和并行操作,而线程共享进程的资源,通信更方便快捷,切换开销较小。本专题为大家提供线程和进程区别相关的各种文章、以及下载和课程。

2023.08.10

4358

6

Python 多线程与异步编程实战
Python 多线程与异步编程实战

本专题系统讲解 Python 多线程与异步编程的核心概念与实战技巧,包括 threading 模块基础、线程同步机制、GIL 原理、asyncio 异步任务管理、协程与事件循环、任务调度与异常处理。通过实战示例,帮助学习者掌握 如何构建高性能、多任务并发的 Python 应用。

2025.12.24

1209

20

java多线程相关教程合集
java多线程相关教程合集

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

2026.01.21

403

30

C++多线程相关合集
C++多线程相关合集

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

2026.01.21

559

24

C# 多线程与异步编程
C# 多线程与异步编程

本专题深入讲解 C# 中多线程与异步编程的核心概念与实战技巧,包括线程池管理、Task 类的使用、async/await 异步编程模式、并发控制与线程同步、死锁与竞态条件的解决方案。通过实际项目,帮助开发者掌握 如何在 C# 中构建高并发、低延迟的异步系统,提升应用性能和响应速度。

2026.02.06

409

20

C++多线程并发控制与线程安全设计实践
C++多线程并发控制与线程安全设计实践

本专题围绕 C++ 在高性能系统开发中的并发控制技术展开,系统讲解多线程编程模型与线程安全设计方法。内容包括互斥锁、读写锁、条件变量、原子操作以及线程池实现机制,同时结合实际案例分析并发竞争、死锁避免与性能优化策略。通过实践讲解,帮助开发者掌握构建稳定高效并发系统的关键技术。

2026.03.16

253

22

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
C++ Core Guidelines
C++ Core Guidelines

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

C++ 官方标准说明
C++ 官方标准说明

共0课时 | 0人学习