下面是一个使用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 命令)来触发信号处理程序。
这个示例展示了如何有效地使用队列来处理信号,从而避免在信号处理程序中执行复杂的逻辑。如果你有更多问题或需要进一步的信息,请告诉我!