如何让子进程定时发送信息且避免系统调用中断？

我正在开发一个进程间通信项目：主程序创建指定数量的子进程，每个子进程通过exec启动，分为两种类型，它们之间通过消息队列通信。要求所有子进程每秒向主程序发送自身状态信息，但现在遇到一个问题：子进程在消息队列等待/写入消息时，频繁出现“系统调用被中断”（EINTR）的情况，导致流程异常。

我尝试过通过循环重试处理EINTR错误，但这个方案无效，子进程始终无法正常结束。另外我考虑在每个子进程内设置内部定时器，但不清楚如何将定时器与消息队列操作结合，以及何时检查时间。

以下是我当前的消息接收函数：

char *receiveMessage(int msgQId, long tipo) {
    my_msg_buf msgBuf;
    sigset_t mask;

    sigemptyset(&mask);
    sigaddset(&mask, SIGUSR1);


    sigprocmask(SIG_BLOCK, &mask, NULL );
    while(1)
    if (msgrcv(msgQId, (void *)&msgBuf, MAX_LINE_LENGTH, tipo, IPC_NOWAIT) == -1) {
        if(errno != ENOMSG && errno != EINTR){
            fprintf(stderr, "Ricevuto errore: %s\n", strerror(errno));
            return NULL;
        }
        if(errno == ENOMSG)
            return NULL;
    }else break;

    sigprocmask(SIG_UNBLOCK, &mask, NULL );

    return strdup(msgBuf.testo);
}

可行解决方案 #

1. 修正EINTR处理逻辑，改用阻塞模式 #

你当前使用IPC_NOWAIT非阻塞模式，会导致循环无意义轮询，既浪费资源又容易陷入无限循环。应该改用阻塞模式（去掉IPC_NOWAIT），并在捕获到EINTR时直接重试：

修改后的接收函数：

char *receiveMessage(int msgQId, long tipo) {
    my_msg_buf msgBuf;
    sigset_t mask;
    ssize_t ret;

    // 阻塞SIGUSR1，避免信号中断msgrcv
    sigemptyset(&mask);
    sigaddset(&mask, SIGUSR1);
    sigprocmask(SIG_BLOCK, &mask, NULL);

    do {
        ret = msgrcv(msgQId, (void *)&msgBuf, MAX_LINE_LENGTH, tipo, 0); // 阻塞模式
        if (ret == -1) {
            if (errno != EINTR) { // 仅处理非EINTR的错误
                fprintf(stderr, "Ricevuto errore: %s\n", strerror(errno));
                sigprocmask(SIG_UNBLOCK, &mask, NULL);
                return NULL;
            }
            // 若为EINTR，直接进入下一轮循环重试
        }
    } while (ret == -1);

    sigprocmask(SIG_UNBLOCK, &mask, NULL);
    return strdup(msgBuf.testo);
}

2. 用SIGALRM实现定时状态发送 #

针对“每秒发送状态”的需求，不需要复杂的内部定时器，直接用SIGALRM信号配合SA_RESTART标志即可：

// 定时触发的状态发送函数
void sigalrm_handler(int signo) {
    sendStatusToParent(); // 这里实现向主进程发送状态的逻辑
}

void child_process_init() {
    struct sigaction sa;
    struct itimerval timer;

    // 配置SIGALRM信号处理
    sa.sa_handler = sigalrm_handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_RESTART; // 关键：让被中断的系统调用自动重启
    sigaction(SIGALRM, &sa, NULL);

    // 设置每秒触发一次SIGALRM
    timer.it_value.tv_sec = 1;
    timer.it_value.tv_usec = 0;
    timer.it_interval.tv_sec = 1;
    timer.it_interval.tv_usec = 0;
    setitimer(ITIMER_REAL, &timer, NULL);
}

SA_RESTART标志会让msgrcv/msgsnd这类系统调用在被信号中断后自动重启，不需要手动写循环重试，能大幅简化代码逻辑。

3. 排查子进程无法结束的原因 #

你之前的方案中子进程无法结束，核心原因是非阻塞模式下，当没有消息（ENOMSG）时会返回NULL，但如果被信号打断触发EINTR，就会进入无限循环。改用阻塞模式+SA_RESTART或者正确的EINTR重试逻辑，就能解决这个问题。

内容的提问来源于stack exchange，提问作者Vasetto