讲师中心 微信公众号
AI工具推荐 视频效率加速

C++如何实现异步定时任务的优先级调度分发引擎架构设计 _ 源码【实战】

酷明大大_5806

酷明大大_5806

发布时间:2026-05-22 15:56:31

|

690人浏览过

|

来源于php中文网

原创

采用多级优先级队列与时间轮混合调度架构,定义三级队列和三层时间轮,任务按优先级和定时双维度定位,调度线程先收集到期任务再轮询执行,结合jthread、协程、条件变量优化及C++26优先级策略实现高效可控调度。

c++如何实现异步定时任务的优先级调度分发引擎架构设计 _ 源码【实战】

一、采用多级优先级队列 + 时间轮混合调度架构

该架构将任务按优先级分层隔离,每级队列独立管理,避免高优先级任务被低优先级阻塞;同时引入时间轮结构支撑毫秒级定时触发,确保延迟可控且不依赖系统时钟跳变。时间轮负责到期扫描,多级队列负责就绪任务分发,二者解耦后可分别优化并发性能。

1、定义三级优先级队列:priority_queue[0](highest)、priority_queue[1](normal)、priority_queue[2](lowest),每个队列使用std::queue<:shared_ptr>>存储,配合独立std::mutex保护。

2、构建三层时间轮:毫秒轮(64槽,1ms/槽)、秒轮(64槽,64ms/槽)、分钟轮(64槽,4096ms/槽),所有槽使用std::array<:list>>, 64>静态分配,规避动态内存开销。

3、任务插入时,先根据scheduled_at计算所属时间轮槽位,再依据priority字段映射至对应优先级队列索引,完成双维度定位。

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

4、调度线程主循环中,每轮先推进时间轮指针并收集所有到期Task,将其按原始priority值插入对应级别队列,不执行回调。

5、随后进入轮询阶段:从highest级别开始,对每一级调用try_lock()获取其mutex,成功则pop一个Task并移交至worker thread pool异步执行;失败或为空则立即跳过,继续下一级。

二、基于std::jthread与stop_token的安全调度生命周期控制

为防止调度器退出时任务丢失或线程挂起,必须将C++26标准的协作式中断机制深度融入调度主循环。stop_token提供原子通知能力,jthread确保自动join,二者结合可实现零资源泄漏的优雅终止。

1、构造调度器时声明std::jthread scheduler_thread{[this](std::stop_token token) { run_scheduler_loop(token); }};

2、在run_scheduler_loop函数首行插入if (token.stop_requested()) break;,确保每次循环入口都响应中断请求。

3、每次尝试获取某级队列锁前,再次检查token.stop_requested(),若为true则跳过该级,避免阻塞在mutex.lock()上。

4、worker thread pool中执行的每个Task回调,均接收std::stop_token参数,并在I/O等待或sleep前调用token.stop_requested()判断是否需提前返回。

5、调度器析构函数中,先调用scheduler_thread.request_stop(),再确保所有pending Task已从时间轮和各级队列中安全移出并标记cancelled,严禁在未清空队列前调用join()。

三、协程化任务封装与无栈挂起调度集成

将Task对象升级为可挂起协程句柄,使定时任务天然支持co_await语义,无需回调嵌套即可表达复杂时序逻辑。协程状态机由编译器生成,调度器仅负责恢复时机决策,极大降低用户代码复杂度。

1、定义task类型:struct task { struct promise_type; using handle_type = std::coroutine_handle; };

2、promise_type中重载initial_suspend()返回std::suspend_always,final_suspend()返回std::suspend_always,确保协程启动即挂起,由调度器显式resume。

C++14
C++14

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

下载

3、Task结构体内嵌handle_type成员,并在scheduled_at到达时,通过handle.resume()交由worker线程恢复执行。

4、协程体内部可自由使用co_await timer.await_after(500ms)等语法,timer为封装了时间轮查询的awaiter对象,其await_ready()必须基于steady_clock::now()实时比对,不可缓存time_point。

5、调度器在恢复协程前,须检查其关联的stop_token及cancelled标志,若任一为true则直接destroy() handle,不执行后续逻辑。

四、优先级感知的条件变量唤醒优化策略

传统条件变量notify_one()无法区分优先级,易导致高优任务等待低优任务释放锁后才被唤醒。本方案改用“优先级门控”机制,在插入高优任务时主动唤醒对应级别等待线程,消除调度毛刺。

1、为每一级优先级队列维护独立的std::condition_variable cv_level[N],而非共用单个cv。

2、任务入队至priority_queue[i]后,立即调用cv_level[i].notify_one(),确保仅该级别等待线程被唤醒。

3、调度线程在轮询某级队列前,先调用cv_level[i].wait_for(lock, 100ms),超时后仍进入try_lock流程,避免无限等待。

4、若某级队列在wait_for期间被notify_one()唤醒,但实际pop时发现为空(虚假唤醒),则继续下一轮轮询,不重置等待时限,防止饥饿。

5、所有cv.wait_for()调用均置于对应级别mutex保护下,且wait前必须确认队列非空,否则立即跳过。

五、基于C++26 priority_policy的底层线程优先级映射

在worker thread pool创建线程时,显式绑定C++26标准的优先级策略,使操作系统调度器能感知任务语义层级,将highest任务映射至更高内核调度优先级,从而在资源争抢时获得CPU时间片倾斜。

1、创建worker线程时使用std::jthread(std::launch::async | std::priority::highest, worker_fn)语法启动关键路径线程。

2、Linux平台下,调度器自动将std::priority::highest映射为SCHED_OTHER策略下的nice值-20,需确保进程具备CAP_SYS_NICE权限,否则降级为normal。

3、Windows平台下,std::priority::highest触发SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_HIGHEST),由系统保证实时响应性。

4、所有worker线程启动后,立即调用std::this_thread::set_unmaskable()(若可用)或绑定CPU亲和性掩码,减少跨核迁移带来的cache失效。

5、低优先级任务线程启用IDLE_PRIORITY_CLASS,并在执行体中插入std::this_thread::yield(),主动让出剩余时间片给前台任务。

热门AI工具

更多
音述AI
音述AI Hot

一款AI音频处理工具,主要用于音述AI是一个以“用声音述说故事”为核心的 AI 音乐创作与声音分享社区,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

VibeKnow
VibeKnow Hot

一款AI视频创作工具,主要用于全球首个AI知识视频创作平台,文档、文章、网页,一键生成视频,适合需要提升相关任务效率的用户。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

相关专题

更多
c++和c语言的区别有哪些
c++和c语言的区别有哪些

c++和c语言的区别:1、面向对象编程(OOP)支持不同;2、新增特性不同;3、标准库不同;4、编译方式不同;5、命名空间不同等等。想了解更多c++的相关内容,可以阅读本专题下面的文章。

2268

2024.03.14

c++和python学习顺序推荐
c++和python学习顺序推荐

一般建议先学习C++,再学习Python,因为这样可以逐步从较为底层的编程语言向更高级的语言过渡。想了解更多python的相关内容,可以阅读本专题下面的文章。

1039

2024.03.14

python和c++学习性价比分析
python和c++学习性价比分析

Python易于学习,广泛应用于Web开发、数据科学和人工智能等领域,但性能较低。C语言性能高,适用于对性能要求较高的场景,如游戏开发和系统编程,但学习曲线陡峭,错误处理复杂。想了解更多python的相关内容,可以阅读本专题下面的文章。

447

2024.03.14

c语言和c++一样吗
c语言和c++一样吗

c语言和c++是两种不同的编程语言,虽然有相似之处,但存在显著差异。c语言专注于过程式编程和系统级开发,以简洁、高效著称。c++作为c语言的超集,引入了面向对象编程,增强了代码组织和管理能力,但学习曲线也更陡峭。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

347

2024.03.14

c语言和c++先学哪个好
c语言和c++先学哪个好

初学者选择学习c语言还是c++语言,需要根据个人学习目标、背景以及编程兴趣和预期应用方向来决定。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

426

2024.03.14

c语言和c++的区别和联系
c语言和c++的区别和联系

c语言和c++是计算机科学领域应用广泛的编程语言。虽然它们有着相似的基础,但它们在语言类型、语法功能和内存管理方面存在着显著差异。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

600

2024.03.14

c++软件中文更改教程
c++软件中文更改教程

对于 ide,可通过打开设置,找到语言设置,选择中文,并保存更改。对于非 ide 应用程序,可查找设置或选项,选择语言设置,更改为中文,并保存更改。想了解更多c++的相关内容,可以阅读本专题下面的文章。

1429

2024.03.21

python和java和c++学习性价比分析
python和java和c++学习性价比分析

Python以其易学性、丰富的库和活跃的社区而著称,适合数据科学、人工智能和Web开发。Java以其跨平台性、企业级应用开发和Android应用开发而闻名。C++以其底层控制能力、高效性能和游戏开发而著称。选择哪种语言取决于个人兴趣、职业方向和特定需求。想了解更多python和java和c++的相关内容,可以阅读本专题下面的文章。

1237

2024.03.22

Vite 项目如何打包和部署
Vite 项目如何打包和部署

Vite项目打包部署专题汇集生产构建、产物预览、输出目录、资源路径、Nginx与GitHub Pages部署及常见白屏和路由404问题的已审核文章,帮助读者完成上线流程。

60

2026.10.28

热门下载

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

精品课程

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

共0课时 | 0人学习

C++ Reference
C++ Reference

共0课时 | 0人学习

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

共0课时 | 0人学习

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn