为什么要用统一事件源

信号是一种异步事件：信号处理函数和程序的主循环是两条不同的执行路径。即当进程收到信号时，操作系统会中断进程当前的正常流程，转而进入信号处理函数去处理信号，完成后再返回中断的地方继续执行。

很显然，信号处理函数需要尽可能地快速执行完毕，以确保该信号不会被屏蔽太久。因为为了避免信号竞态条件的发生，信号处理期间系统不会再次触发它。

解决方法：
一种典型的解决方法是：把信号的主要处理逻辑放到程序的主循环中，当信号处理函数被触发时，它只是简单的通知主循环程序接收到信号，并把信号值传递给主循环，主循环再根据接收到的信号执行目标信号对应的逻辑代码。

信号处理函数通常使用管道来将信号“传递”给主循环的：信号处理函数往管道的写端写入信号值，主循环则从管道的读端读出信号值。那么主循环怎么知道管道上何时有数据可读呢？这很简单，我们只需要使用I/O复用系统调用来监听管道的读端文件描述符上的可读事件。如此一来，信号事件就能和其他I/O事件一样被处理了。

统一事件源的概念

统一事件源，即将信号和其他事件一样进行处理。

具体就是信号处理函数使用管道将信号传递给主循环，信号处理函数往管道的写端写入信号值，主循环则从管道的读端读出信号值，使用I/O复用系统调用来监听管道读端的可读事件，这样信号事件与其他文件描述符都可以通过epoll来监测，从而实现统一处理。

很多优秀的I/O框架库和后台服务器程序都统一处理信号和I/O事件，比如Libevent I/O 框架库和 xinetd 超级服务。以下是一个统一事件源的简单实现。

统一事件源的应用

信号处理函数：

//信号处理函数
void sig_handler(int sig)
{
    //保留原来的errno，在函数最后恢复，以保证函数的可重入性
    int save_errno = errno;
    int msg = sig;
    send(pipefd[1], (char* )&msg, 1, 0);
    errno = save_errno;
}

这里信号处理的方式只是通过管道向主循环发生信号，将信号交给主喜欢出现进行处理，以达到统一事件源的目的。

添加信号到信号处理函数：

void addsig(int sig)
{
	//创建sigaction结构体变量
    struct sigaction sa;
    memset(&sa, 0, sizeof(sa));
    //信号处理函数中仅仅发送信号值，不做对应逻辑处理
    sa.sa_handler = sig_handler;
    sa.sa_flags |= SA_RESTART;
    //将所有信号添加到信号集中
    sigfillset(&sa.sa_mask);
    //执行sigaction函数
    assert(sigaction(sig, &sa, nullptr) != -1);
}

这里使用了 sigaction 系统调用来设置信号处理函数，相比于 signal 系统调用具有更强的健壮性。

信号通知逻辑：

使用socketpair创建管道，其中写端由信号处理函数写入信号值，主循环程序通过 epoll I/O复用监视读事件就绪时从管道的读端读取信号。
这里主要设置了对SIGTERM(kill -15)和SIGTINT(ctrl + C) 信号的处理，通过struct sigaction结构体和sigaction系统调用注册对信号的捕捉和处理。
利用epoll 监测管道读端的读事件就绪。
当主循环收到这两个信号时安全的退出程序。

具体逻辑代码如下：

epoll_event events[MAX_EVENT_NUMBER];
int epollfd = epoll_create(5);
assert(epollfd != -1);

addfd(epollfd, listenfd);

// 使用 socketpair 创建管道，注册 pipefd[0] 上的可读事件
ret = socketpair(AF_UNIX, SOCK_STREAM, 0, pipefd);
assert(ret != -1);

setNonBlock(pipefd[1]);
addfd(epollfd, pipefd[0]);

//设置一些信号的处理函数
addsig(SIGHUP);
addsig(SIGCHLD);
addsig(SIGTERM);
addsig(SIGINT);

bool stop_server = false;
while (!stop_server)
{
    int number = epoll_wait(epollfd, events, MAX_EVENT_NUMBER, -1);
    if(number < 0 && errno != EINTR)
    {
        printf("epoll wait failure!\n");
        break;
    }

    for(int i = 0; i < number; ++i)
    {
        int sockfd = events[i].data.fd;
        //如果就绪的文件描述符是listenfd, 则处理新连接
        if(sockfd == listenfd)
        {
            sockaddr_in peer;
            socklen_t len = sizeof(peer);

            int connfd = accept(listenfd, (sockaddr*)&peer, &len);
            addfd(epollfd, connfd);
        }
        //如果就绪的文件描述符是pipefd[0]，就处理信号
        else if(sockfd == pipefd[0] && (events[i].events & EPOLLIN))
        {
            int sig;
            char signals[1024];
            ssize_t s = recv(pipefd[0], signals, sizeof(signals), 0);
            if(s == -1)
            {
                continue;
            }
            else if(s == 0)
            {
                continue;
            }
            else
            {
                //每个信号占一个字节，所以按照字节来逐个接收信号。此处以SIGTERM为例，来安全的终止服务器程序：
                for(int i = 0; i < s; ++i)
                {
                    switch (signals[i])
                    {
                    case SIGCHLD:
                    case SIGHUP:
                    {
                        continue;
                    }
                    case SIGTERM:
                    case SIGINT:
                    {
                        stop_server = true;
                    }
                    default:
                        break;
                    }
                }
            }
        }
        else
        {
            //其他I/O就绪
        }
    }
}

printf("close fds\n");
close(listenfd);
close(pipefd[0]);
close(pipefd[1]);