您的位置:首页 > 移动开发

分析Poco中ServerApplication监听中断机制

2014-06-04 17:21 417 查看
使用Poco::Util::ServerApplication构建Tcp服务器,我们打算在住循环中设置中断机制,仔细考察Poco代码,发现已经提供一个比较完善的方案。

Poco::Util::ServerApplication监听中断机制,主要是通过waitForTerminationRequest()实现的,该函数被调用后,将阻塞调用他的线程,直到收到监听的信号,函数源码如下。

void ServerApplication::waitForTerminationRequest()
{
sigset_t sset;
sigemptyset(&sset);
if (!std::getenv("POCO_ENABLE_DEBUGGER"))
{
sigaddset(&sset, SIGINT);
}
sigaddset(&sset, SIGQUIT);
sigaddset(&sset, SIGTERM);
sigprocmask(SIG_BLOCK, &sset, NULL);
int sig;
sigwait(&sset, &sig);
}


1. sigset_t sset; // 设置信号集

2. sigemptyset(&sset); // 置空信号集

3. sigaddset(&sset, SIGINT); // 程序终止(interrupt)信号, 在用户键入INTR字符(通常是Ctrl-C)时发出

sigaddset(&sset, SIGQUIT); // 程序终止(interrupt)信号, 由QUIT字符(通常是Ctrl-\)来控制

sigaddset(&sset, SIGTERM); // 程序结束(terminate)信号, 与SIGKILL不同的是该信号可以被阻塞和处理。通常用来要求程序自己正常退出,

4. sigprocmask设定对信号屏蔽集内的信号的处理方式(阻塞或不阻塞),waitForTerminationRequest明显是阻塞。

5. 核心实现是利用sigwait(&sset, &sig),sigwait监听信号集sset中所包含的信号,并将其存在sig中。sigwait函数在调用后将阻塞调用他的线程,直到收到它所监听的信号发生了,然后sigwait将其从未决队列中取出。

6. 同时,Poco::Util::ServerApplication提供一个terminate()接口,用于发送程序结束信号SIGTERM,用于正常结束整个进程。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: