我正在尝试在接收到 SIGINT 信号(^C
它是)时正确终止我的多线程 C++11 应用程序,但由于某种原因,它不会传播到子线程,尽管主线程对它的响应很好。
例如(如下面的代码示例),如果我们在线程内部有一个阻塞函数sleep()
(比如^C
sigaction()
有没有办法修复或解决这种行为?有没有办法将主接收的信号传播到子线程?
编辑sleep()
:用 C++11替换 POSIXstd::this_thread::sleep_for()
#include <iostream>
#include <thread>
#include <chrono>
#include <signal.h> // for sigaction() function
static int signaled = 0;
void threaded_foo() {
while (!signaled) {
// pressing ^C now will not lead to correct termination, because we are
// sleeping for a long time (100500 seconds) and do not respond to
// SIGINT for some tricky reason i am looking a bypassage for.
std::chrono::seconds duration(100500);
std::this_thread::sleep_for(duration);
}
std::cout << "Correct termination\n";
}
void sighandler(int sig, siginfo_t *siginfo, void *context) {
signaled = 1;
}
void install_sig_hooks() {
struct sigaction action;
memset(&action, 0, sizeof(struct sigaction));
action.sa_sigaction = sighandler;
action.sa_flags = SA_SIGINFO;
sigaction(SIGINT, &action, NULL);
}
int main(int argc, char **argv) {
install_sig_hooks();
std::thread t(threaded_foo);
t.join();
return 0;
}
EDIT2 因此,解决方案是用非阻塞对应项以及条件变量和轮询等机制替换所有阻塞调用。
实际问题仍未得到解答,因为当前的软件(可能还有硬件)的设计方式不是在一个线程中处理信号,而是应该告诉其他人在接收信号时要做什么。