Linux管道SIGIO信号捕获：替代select()的管道数据通知代码问询

嘿，我看了你这段想用SIGIO监听管道数据的代码，先帮你把代码补全并梳理下核心问题，再给你调整后的可运行版本参考～

首先先把你给出的代码片段完整呈现（补全main函数未写完的部分）：

#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>

void handler (int x) {
    int fd, st;
    char buf[32];
    printf("signal_entry\n");
    fd = open("/tmp/pipe", O_RDWR);
    memset(buf, 0, sizeof(buf));
    st = read(fd, buf, 32);
    printf("st: %d buf: %s\n", st, buf);
    close(fd);
    printf("signal_exit\n\n");
}

int main (void) {
    int fd, sf, fl, st, num;
    struct sigaction sa;

    // 假设你原本想设置信号处理
    sa.sa_handler = handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = 0;
    sigaction(SIGIO, &sa, NULL);

    // 这里可能遗漏了关键的O_ASYNC和F_SETOWN设置
    return 0;
}

你这段代码的几个核心问题： #

• 重复打开/关闭管道效率极低且有风险：每次收到SIGIO都重新打开管道，不仅浪费系统资源，还可能因为管道的字节流特性，导致数据丢失或重复读取的问题。应该在main函数中提前打开管道并保持文件描述符。
• 信号处理函数使用非可重入函数：printf不是可重入函数，在信号处理上下文调用可能引发竞态条件，导致程序崩溃或输出混乱。推荐用write（系统调用，可重入）来输出信息到stderr。
• 缺少SIGIO触发的必要配置：要让内核给进程发送SIGIO，必须给管道的文件描述符设置O_ASYNC标志，并且用fcntl的F_SETOWN将当前进程ID绑定到该文件描述符，否则内核不会主动发送SIGIO信号。

调整后的可运行版本： #

#include <stdio.h>
#include <stdlib.h>
#include <signal.h>
#include <unistd.h>
#include <fcntl.h>
#include <string.h>
#include <errno.h>

static int pipe_fd; // 全局保存管道文件描述符，信号处理函数可访问

void sigio_handler(int sig) {
    char buf[32];
    ssize_t st;

    // 用write替代printf，保证可重入
    const char entry_msg[] = "signal_entry\n";
    write(STDERR_FILENO, entry_msg, strlen(entry_msg));

    memset(buf, 0, sizeof(buf));
    st = read(pipe_fd, buf, sizeof(buf)-1); // 留一个字节给终止符
    if (st == -1) {
        const char err_msg[] = "read failed\n";
        write(STDERR_FILENO, err_msg, strlen(err_msg));
        return;
    }

    char output[64];
    snprintf(output, sizeof(output), "st: %zd buf: %s\n", st, buf);
    write(STDERR_FILENO, output, strlen(output));

    const char exit_msg[] = "signal_exit\n\n";
    write(STDERR_FILENO, exit_msg, strlen(exit_msg));
}

int main(void) {
    struct sigaction sa;
    int flags;

    // 先创建FIFO（如果不存在）
    if (mkfifo("/tmp/pipe", 0666) == -1 && errno != EEXIST) {
        perror("mkfifo failed");
        exit(EXIT_FAILURE);
    }

    // 打开管道，保持文件描述符
    pipe_fd = open("/tmp/pipe", O_RDONLY | O_NONBLOCK); // 用O_NONBLOCK避免read阻塞
    if (pipe_fd == -1) {
        perror("open pipe failed");
        exit(EXIT_FAILURE);
    }

    // 配置SIGIO信号处理
    sa.sa_handler = sigio_handler;
    sigemptyset(&sa.sa_mask);
    sa.sa_flags = SA_RESTART; // 让被中断的系统调用自动重启
    if (sigaction(SIGIO, &sa, NULL) == -1) {
        perror("sigaction failed");
        close(pipe_fd);
        exit(EXIT_FAILURE);
    }

    // 设置O_ASYNC标志，让内核发送SIGIO
    flags = fcntl(pipe_fd, F_GETFL);
    if (flags == -1) {
        perror("fcntl F_GETFL failed");
        close(pipe_fd);
        exit(EXIT_FAILURE);
    }
    if (fcntl(pipe_fd, F_SETFL, flags | O_ASYNC) == -1) {
        perror("fcntl F_SETFL O_ASYNC failed");
        close(pipe_fd);
        exit(EXIT_FAILURE);
    }

    // 将当前进程ID绑定到管道fd，内核会给该进程发SIGIO
    if (fcntl(pipe_fd, F_SETOWN, getpid()) == -1) {
        perror("fcntl F_SETOWN failed");
        close(pipe_fd);
        exit(EXIT_FAILURE);
    }

    // 主进程保持运行，等待信号
    while (1) {
        pause(); // 挂起进程直到收到信号
    }

    close(pipe_fd);
    return 0;
}

关键改进点说明： #

• 全局保存管道文件描述符，避免重复打开/关闭
• 信号处理函数中用write替代printf，保证可重入性
• 添加O_NONBLOCK标志，避免read在信号处理中阻塞（如果管道没有数据，read会立即返回-1，errno设为EAGAIN）
• 配置SA_RESTART标志，让被信号中断的系统调用自动重启
• 完整设置O_ASYNC和F_SETOWN，确保内核会在管道有数据时发送SIGIO信号
• 提前创建FIFO（如果不存在），避免打开失败

使用时，你可以在另一个终端用echo "test" > /tmp/pipe来向管道写入数据，就能看到信号处理函数被触发啦～

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