10

我试图从分叉进程的 STDOUT 中读取。但是,如果我正在无限地从管道中读取,for loop即使没有数据通过管道,它也会忙于等待(如果我错了,请纠正我),我想必须有更好的方法来做如果它是短时间间隔使用sleep,可能是回调,我不确定。以下是我尝试过的代码片段。

pid_t pid = fork();  
switch (pid) {
    case 0:
        dup2 (pipes[1], STDOUT_FILENO );
        dup2(pipes[1], STDERR_FILENO); 
        close(pipes[0]); 
        close(pipes[1]);
        execv(path, args);
        break;
    default :
        close(STDIN_FILENO);
        close(STDOUT_FILENO);
        close(STDERR_FILENO);
        child_pid = pid;
        signal(SIGHUP, mysighandle);
        close(pipes[1]); 
        ssize_t nbytes;
        for (;;) {
            nbytes = read(pipes[0], buf, BUFSIZE); 
            if (nbytes == -1){
                break;
            }
            if (nbytes == 0) {
                break;
            }
            syslog(LOG_NOTICE, "%s", buf);

有人可以建议一个更好的方法,而不是忙着等待,可以用来从管道中读取数据吗?由于我是初学者C,因此对代码片段的任何引用都值得赞赏。

问候。

4

1 回答 1

9

在您的代码中,您没有将管道设置为非阻塞模式(至少,我假设您没有,因为您实际上并没有显示您是如何打开它的),因此read()进行阻塞读取也是如此。也就是说,如果没有可用数据,但某些进程仍然打开管道进行写入,那么它将自动暂停您的进程,直到有更多数据可用(然后将该数据读入缓冲区)。

因此,您的代码可以正常工作,无需更改它。

(也就是说,除非您想同时从多个管道读取数据,或者在等待数据的同时还在同一个线程中执行其他操作,在这种情况下,您确实应该使用select()和(可能)非阻塞 I/O。)

于 2016-10-24T13:11:57.373 回答