冲洗管道的缓冲区

Question

我正在玩管道，并从here采取以下代码;一旦我明白了，我看到一个数据块缓存的问题，我添加了一个电话到sleep()，这是不存在的原始代码：

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

int main() 
{ 
    FILE *ps_pipe; 
    FILE *grep_pipe; 

    int bytes_read; 
    int nbytes = 100; 
    char *my_string; 

    char buffer[100]; 

    /* Open our two pipes */ 
    ps_pipe = popen ("ls", "r"); 
    grep_pipe = popen ("sort", "w"); 

    /* Check that pipes are non-null, therefore open */ 
    if ((!ps_pipe) || (!grep_pipe)) 
    { 
     fprintf (stderr, 
       "One or both pipes failed.\n"); 
     return EXIT_FAILURE; 
    } 

    bytes_read = 0; 
    while (fgets(buffer, sizeof(buffer), ps_pipe)) 
    { 
     fprintf(grep_pipe, "%s", buffer); 
     bytes_read += strlen(buffer); 
    } 

    printf("Total bytes read = %d\n", bytes_read); 
    sleep(2); 

    /* Close ps_pipe, checking for errors */ 
    if (pclose(ps_pipe) != 0) 
    { 
     fprintf(stderr, "Could not run 'ps', or other error.\n"); 
    } 

    /* Close grep_pipe, cehcking for errors */ 
    if (pclose(grep_pipe) != 0) 
    { 
     fprintf(stderr, "Could not run 'grep', or other error.\n"); 
    } /* Exit! */ 

    return 0; 
} 

EDIT [这是错的，见下面的回答]：这样，一旦程序从其主函数返回，我确信管道的缓冲区被刷新。

但是，我仍然不明白原因：为什么管道的内核缓冲区会刷新到标准输出？前者与后者有什么关系？ [编辑：这也是错误的，但留给上下文]

Answer 1

睡眠对任何内核缓冲区没有影响。

您在stdout上看到的输出来自sort过程，并通过关闭grep_pipe触发。

你的程序实际上是模仿下面的shell脚本：

ls | sort 

你打开一个管道从ls阅读，消耗所有的输出（来自其stdout）和该输出发送到的该stdinsort过程。 sort无法对行进行排序，直到它包含所有行，并且只有当它关闭stdin时才知道它具有所有行，当您关闭grep_pipe时会发生这种情况。

一旦grep_pipe关闭，sort完成其工作，生成排序的行到其stdout。 pclose直到关联的进程已终止才会返回，此时sort将完成生成其所有输出。