信号处理以及队列

下面是一个使用C++和POSIX信号处理以及队列的简单示例。这个示例展示了如何使用信号处理程序将信号放入队列中，并在主循环中处理这些信号。

#include <iostream>
#include <csignal>
#include <queue>
#include <mutex>
#include <thread>
#include <chrono>std::queue<int> signalQueue; // 信号队列
std::mutex queueMutex; // 互斥锁，用于保护队列// 信号处理程序
void signalHandler(int signal) {std::lock_guard<std::mutex> lock(queueMutex); // 锁定队列signalQueue.push(signal); // 将信号放入队列std::cout << "Signal " << signal << " received and added to queue." << std::endl;
}// 主处理函数
void processSignals() {while (true) {std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟处理间隔std::lock_guard<std::mutex> lock(queueMutex); // 锁定队列while (!signalQueue.empty()) {int signal = signalQueue.front(); // 获取队列前端信号signalQueue.pop(); // 移除信号std::cout << "Processing signal: " << signal << std::endl;}}
}int main() {// 注册信号处理程序std::signal(SIGINT, signalHandler); // 处理Ctrl+C信号std::signal(SIGTERM, signalHandler); // 处理终止信号// 启动信号处理线程std::thread processor(processSignals);// 主线程继续运行std::cout << "Press Ctrl+C to send SIGINT or send SIGTERM to terminate." << std::endl;// 等待处理线程结束processor.join();return 0;
}

代码说明：
信号处理程序：当接收到信号（如SIGINT或SIGTERM）时，信号处理程序会将信号放入一个线程安全的队列中。
主处理函数：在一个单独的线程中，主处理函数定期检查队列，并处理所有待处理的信号。
互斥锁：使用互斥锁确保对队列的访问是线程安全的。
使用方法：
编译并运行程序。
按 Ctrl+C 或发送 SIGTERM 信号（例如使用 kill 命令）来触发信号处理程序。
这个示例展示了如何有效地使用队列来处理信号，从而避免在信号处理程序中执行复杂的逻辑。如果你有更多问题或需要进一步的信息，请告诉我！