C程序中sigsuspend致第二个子进程无法接收管道消息的问题

问题根源分析 #

你的程序偶尔出现阻塞，核心原因是竞态条件或文件描述符管理混乱，常见触发场景包括：

• 父进程在第二个子进程还未打开管道读端时就发起写入，导致write()调用阻塞等待读端就绪
• 信号计数变量未做同步处理，父进程提前开始写入操作
• 子进程继承了父进程的管道写端却未及时关闭，导致管道引用计数异常，无法触发正确的EOF或阻塞逻辑

具体修复方案 #

1. 规范管道的创建与文件描述符管理 #

匿名管道的核心是严格管控读写端的生命周期，多余的描述符必须及时关闭：

• 父进程创建管道后，立即关闭不需要的读端，只保留写端
• 子进程fork后，第一时间关闭继承自父进程的无关描述符，只保留自己需要的读端
• 子进程必须在发送信号前就准备好管道读端，不能等发完信号再打开——否则父进程可能先触发写入，此时读端未就绪，父进程会一直阻塞

示例代码片段：

// 父进程创建两个匿名管道
int fds_1[2], fds_2[2];
pipe(fds_1);
pipe(fds_2);

// 父进程仅保留写端，关闭读端
close(fds_1[0]);
close(fds_2[0]);

// 子进程1逻辑
pid_t pid1 = fork();
if (pid1 == 0) {
    // 关闭所有无关描述符
    close(fds_1[1]);
    close(fds_2[0]);
    close(fds_2[1]);
    
    // 向父进程发送信号
    sigqueue(getppid(), SIGUSR1, (union sigval){.sival_int = 1});
    
    // 等待读取父进程消息
    char buf[100];
    read(fds_1[0], buf, sizeof(buf));
    printf("子进程1收到：%s\n", buf);
    close(fds_1[0]);
    exit(0);
}

// 子进程2逻辑同理
pid_t pid2 = fork();
if (pid2 == 0) {
    close(fds_2[1]);
    close(fds_1[0]);
    close(fds_1[1]);
    
    sigqueue(getppid(), SIGUSR2, (union sigval){.sival_int = 2});
    
    char buf[100];
    read(fds_2[0], buf, sizeof(buf));
    printf("子进程2收到：%s\n", buf);
    close(fds_2[0]);
    exit(0);
}

2. 修复信号计数的同步问题 #

用普通变量统计信号数量，会因为编译器优化或CPU缓存导致父进程无法及时看到变量更新，必须使用信号安全的变量类型：

• 将计数变量声明为volatile sig_atomic_t，这是信号处理函数中唯一安全的变量类型
• 父进程用pause()挂起等待信号，比轮询更高效且避免空耗CPU

示例：

#include <signal.h>

volatile sig_atomic_t sig_count = 0;

void sig_handler(int sig) {
    if (sig == SIGUSR1 || sig == SIGUSR2) {
        sig_count++;
        // 注意：正式代码中禁止在信号处理函数内调用printf，这里仅作测试
        printf("收到信号：%d\n", sig);
    }
}

// 父进程注册信号处理函数
signal(SIGUSR1, sig_handler);
signal(SIGUSR2, sig_handler);

// 等待两个子进程的信号都收到
while (sig_count < 2) {
    pause();
}

3. 处理写入操作的中断异常 #

写入管道时可能被信号中断（触发EINTR错误），需要循环重试确保写入完成：

#include <errno.h>
#include <string.h>

// 向子进程1发送消息
const char* msg1 = "给子进程1的消息";
ssize_t write_bytes;
do {
    write_bytes = write(fds_1[1], msg1, strlen(msg1) + 1);
} while (write_bytes == -1 && errno == EINTR);

// 向子进程2发送消息同理
const char* msg2 = "给子进程2的消息";
do {
    write_bytes = write(fds_2[1], msg2, strlen(msg2) + 1);
} while (write_bytes == -1 && errno == EINTR);

额外注意事项 #

• 信号处理函数内禁止调用非异步信号安全的函数（如printf），正式代码请改用write(STDOUT_FILENO, ...)
• 所有文件描述符必须在使用完毕后关闭，避免资源泄漏或管道状态异常
• 如果需要更严谨的同步，可以让父进程收到信号后回发确认信号，子进程收到确认后再等待读管道（会增加复杂度，但能彻底消除竞态）

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