不能直接用std::signal或sigaction做多优先级分发,因其抢占式无队列机制导致信号丢失、无优先级调度,且信号处理函数中禁止调用多数c++标准库;必须用自管道将信号转为i/o事件,在安全上下文中分发。

为什么不能直接用 std::signal 或 sigaction 做多优先级分发
因为操作系统层面的信号处理是「抢占式+无队列」的:同一信号多次触发,未决信号只保留一个;不同信号之间没有优先级调度能力;signal 处理函数里禁止调用大部分 C++ 标准库(比如 std::cout、new、std::mutex),根本没法做异步解耦。你试图在信号 handler 里 push 到 priority_queue?会崩溃或未定义行为。
必须用自管道(self-pipe trick)绕过信号安全限制
核心思路是:把信号拦截转成 I/O 事件。在主线程创建一对 socketpair(或 pipe),在信号 handler 里只做最安全的 write(写入信号编号);另一端用 epoll/poll/kqueue 或线程池监听,再在安全上下文中分发。
- Linux 下推荐
socketpair(AF_UNIX, SOCK_STREAM, 0, fd),比pipe更易控制非阻塞 - 注册信号时必须用
sigprocmask屏蔽目标信号,否则可能在 write 中间被再次中断 - 写入内容建议是单字节信号值(如
write(selfpipe_fd[1], &sig, 1)),避免sizeof(int)跨平台差异 - 读端必须循环
read直到EAGAIN,因为一次可有多个信号积压
优先级队列怎么嵌进事件循环不掉帧
不能每个信号都新建一个 std::priority_queue 实例——构造/析构开销大,且无法跨线程安全消费。正确做法是:一个中心队列 + 外部驱动调度。
- 用
std::vector<:function>>*</:function>数组,下标即优先级(0=最高),避免堆分配延迟 - 分发线程每次从高到低扫描,对非空 vector 调用
std::move后清空,防止锁粒度太大 - 如果用
std::priority_queue<:tuple std::function>>></:tuple>,注意比较器必须是严格弱序,且int优先级相同时要加时间戳字段,否则等效任务可能乱序 - 别在信号回调里捕获大对象(如
[big_obj = std::move(x)]() {...}),移动成本不可控,容易拖慢信号响应
如何让业务模块注册时不耦合调度器实现
关键在抽象出信号→回调的绑定契约,而不是暴露队列或线程细节。
立即学习“C++免费学习笔记(深入)”;
- 提供
on_signal(int sig, int priority, std::function<void> cb)</void>接口,内部把cb包装成带优先级的 functor 存入对应 vector - 不要让用户传
std::thread::id或std::shared_ptr<dispatcher></dispatcher>,用静态单例或依赖注入容器管理生命周期更稳妥 - 若支持取消注册,必须用句柄(handle)而非裸函数指针——因为
std::function无法比较相等,得靠std::any或自增 ID 匹配 - 注意
SIGCHLD这类信号需要waitpid(-1, &status, WNOHANG)配套清理,否则注册了也收不到后续触发
真正难的是信号与业务语义对齐:比如 SIGHUP 在配置热更场景该走高优先级同步重载,但在日志轮转里可能只是中优先级异步触发。优先级不是信号固有属性,是业务上下文决定的——这点很容易被忽略。










