Python 3中子进程睡眠时管道读操作阻塞问题求助

首先得搞清楚为啥会阻塞——这是管道（或你使用的IPC机制）的阻塞IO特性在搞鬼。当你用read()从管道读取数据时，如果管道内还有未读完的数据，或者写端未被关闭，read()就会一直等待，直到有新数据写入或写端关闭。

你现在的情况是子进程发送完字符串后直接进入sleep，但它没有关闭管道的写文件描述符，父进程的read()会认为“子进程后续还可能发数据”，于是一直阻塞在读取操作上，直到子进程sleep结束或关闭写端。

下面给你几个实用的解决思路，可根据你的业务需求选择：

1. 发送完数据后先关闭写端再sleep（适合单次发送场景） #

如果子进程本次发完消息后，暂时不需要再向父进程发送数据，可在sleep前关闭管道的写端。这样父进程读完现有数据后，read()会返回0（表示写端关闭），不会再阻塞。

举个C语言的示例（假设使用pipe）：

// 子进程代码
write(pipe_fd[1], "hello parent", 13);
close(pipe_fd[1]); // 关闭管道写端
sleep(10); // 此时父进程read不会再阻塞

注意：如果后续子进程还需要发送数据，这个方法不适用，因为管道文件描述符关闭后无法复用，可参考下面的方案。

2. 给消息添加边界，父进程读到边界即停止 #

比如约定每个消息以换行符\n结尾，父进程每次读到换行符就停止读取，而非一直等待缓冲区填满。这样即使子进程进入sleep，父进程读完带边界的消息后就会返回，不会持续阻塞。

父进程读取逻辑示例：

char buf[1024];
int idx = 0;
while (idx < sizeof(buf)-1) {
    ssize_t n = read(pipe_fd[0], &buf[idx], 1);
    if (n <= 0) break;
    if (buf[idx] == '\n') {
        idx++;
        break;
    }
    idx++;
}
buf[idx] = '\0';
// 处理buf中的消息

3. 使用非阻塞IO读取 #

将父进程的读文件描述符设置为非阻塞模式，这样read()在无数据可读时会立刻返回-1，且errno会被设为EAGAIN或EWOULDBLOCK，你可以在循环中处理这种情况，比如先去执行其他任务，稍后再重试读取。

设置非阻塞模式的代码：

int flags = fcntl(pipe_fd[0], F_GETFL, 0);
fcntl(pipe_fd[0], F_SETFL, flags | O_NONBLOCK);

父进程读取逻辑示例：

char buf[1024];
ssize_t n = read(pipe_fd[0], buf, sizeof(buf));
if (n > 0) {
    // 处理读取到的数据
} else if (n == -1 && errno != EAGAIN) {
    // 处理读取错误
} else {
    // 无数据可读，执行其他操作后重试
    usleep(100000);
}

4. 使用IO多路复用（select/poll/epoll） #

这种方法更优雅，适合同时处理多个IO事件的场景。父进程通过select()监听管道读端，只有当管道有数据可读时才调用read()，否则可以处理其他任务，或在select()上设置超时时间，避免永久阻塞。

select()示例代码：

fd_set read_fds;
struct timeval tv;

FD_ZERO(&read_fds);
FD_SET(pipe_fd[0], &read_fds);

// 设置超时时间，例如等待5秒
tv.tv_sec = 5;
tv.tv_usec = 0;

int ret = select(pipe_fd[0]+1, &read_fds, NULL, NULL, &tv);
if (ret == -1) {
    // 处理select错误
} else if (ret == 0) {
    // 超时，无数据可读，执行其他操作
} else {
    if (FD_ISSET(pipe_fd[0], &read_fds)) {
        char buf[1024];
        ssize_t n = read(pipe_fd[0], buf, sizeof(buf));
        // 处理读取到的数据
    }
}

你可以根据自身应用场景选择最适配的方案，比如单次发送场景选方案1，多次发送场景选方案2、3或4。

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