我已经使用一根管道成功地输送了一条命令的输出。
我想用N个连续的命令执行此操作,其中每个命令代表一个进程。
这是我尝试流水线处理一条命令的尝试,因此要执行N个命令序列,我需要n-1个管道吗?以及所有过程之父如何收集输出并打印输出。
谢谢你。
#include <stdio.h>
#include <unistd.h>
#include <sys/wait.h>
#include <string.h>
int main(int argc ,char *argv[])
{
int i,pid;
int fd[2];//crea i descriptor
char phrase[30][30];//crea il buffer
pipe(fd); /* crea la pipe */
for(i=0;i<argc;i++)
{
if((pid=fork())==0)
{
strcpy(phrase[i], argv[i+1]);
printf("ho scritoo :'%s'\n",phrase);
close(fd[0]); /* chiude in lettura */
write(fd[1],phrase[i],strlen(phrase[i])+1); /* invia anche 0x00 */
close (fd[1]); // chiude in scrittura
// pid=0 -> figlio
usleep(50000*(1+i)); // Ritardo iniziale
printf("Figlio: %d\n",i+1); // Stampa messaggio del figlio
usleep(500000*(1+i)); // Ritardo finale
return(101+i); // Termina con codice di ritorno
} else {
printf("Ho generato il figlio %d con pid %d\n",i+1,pid);
char message[100]; //creare il buffer
memset(message,0,100);
int bytesread;
bytesread = read(fd[0],message,sizeof(message));
printf("ho letto dalla pipe %d bytes: '%s' \n",bytesread,message);
// close(fd[0]);
}
}
close(fd[0]); /* chiude in scrittura */
close(fd[1]); /* chiude in scrittura */
// Attende che dieci processi terminino
for(i=0;i<argc-1;i++)
{
int status;
wait(&status); // Attende termine di un figlio (uno qualunque)
printf("Terminato processo %d\n",WEXITSTATUS(status));
}
return 0;
}
最佳答案
是的,您将拥有用于N个进程的N-1个管道。您可以将所有进程都打印到stdout。由于每个子进程都将继承父级的stdout,因此它们都将打印到父级stdout设置为的任何值。如果通过将stdout重定向到文件来启动链,那么它们将全部打印到该文件。问题将同步他们的写操作,这样他们就不会在另一个写操作的中间进行写操作。
如果要将所有子级输出通过管道传递回原始父级,则可以让每个子级仅将其从其子级管道读取的所有内容写入其父级管道。每个孩子都以这种方式将其传递到链上。
关于c - N个命令管道“进程间”,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/15861924/