fork와 pipe를 사용해서 순환하는 작업
글쓴이: andylhw / 작성시간: 일, 2021/04/18 - 10:31오후
fork와 pipe를 사용해서 순환해서 계속 일을 처리해야되는 프로그램을 만들어야 하는데,
부모-1번,2번,3번,4번자식을 만든 이후로, 저 순서대로 작업 후, 계속 반복을 해야하는데,
for문을 사용해서 프로세스를 생성한 후, 주어진 pipe를 이용해서 새로운 데이터를 넣고 싶은데,
여기서 더 진행하게 하려면, 반복문의 숫자를 증가시켜야 한다고 생각을 합니다.
근데 그렇게 되면, 부모-1-2-3-4-부모-1 가 아닌, 쓰이지 않을 프로세스가 계속 생성될 것 같은데(fork가 계속 호출됨), 이부분은 어떻게 해결해야하는지 궁금합니다.
#include <stdlib.h> #include <stdio.h> #include <unistd.h> #include <sys/time.h> #define FORWARD 1 #define REVERSE 0 int main(void){ char buffer[BUFSIZ]; int fd[5][2][2]; int read_status = 0; //파이프 생성. //i,0 -> i번째에서 i+1번째에게 받는거, i,1 -> i번째에서 i+1번째에게 보내는거 for (int i=0;i<5;i++){ for(int j=0;j<2;j++){ if(pipe(fd[i][j])==-1){ perror("pipe error..\n"); exit(0); } } } int pid; int len; int test1; int my_pid; int fpos; my_pid = getpid(); for(int i=0;i<5;i++){ if(getpid() != my_pid){ exit(0); } pid = fork(); if(pid == -1){ perror("fork error..\n"); exit(0); } else if(pid==0){ //자식 프로세스의 경우// pid = getpid(); printf("Child process %d created.\n", pid); /* if(read(fd[1][FORWARD][0], buffer, BUFSIZ)>0){ printf("\tComplete %s\n", buffer); } */ if(i==0){ write(fd[1][FORWARD][1], "Hi. I'm First!", BUFSIZ); printf("Write Complete!\n"); } else if(i==1){ read(fd[1][FORWARD][0], buffer, BUFSIZ); printf("Output of child process(%d) :: %s \n",pid ,buffer); write(fd[2][FORWARD][1], "Hi. I'm Second!", BUFSIZ); } else if(i==2){ read(fd[2][FORWARD][0], buffer, BUFSIZ); printf("Output of child process(%d) :: %s \n",pid ,buffer); write(fd[3][FORWARD][1], "Hi. I'm Third!", BUFSIZ); } else if(i==3){ read(fd[3][FORWARD][0], buffer, BUFSIZ); printf("Output of child process(%d) :: %s \n",pid ,buffer); write(fd[4][FORWARD][1], "Hi. I'm Forth!", BUFSIZ); } } else{ //부모 프로세스의 경우// pid = getpid(); if(i==4){ read(fd[4][FORWARD][0], buffer, BUFSIZ); printf("Output of parent process(%d) :: %s \n",pid ,buffer); write(fd[0][FORWARD][1], "Hi. I'm Forth!", BUFSIZ); } } sleep(1); } exit(0); }
Forums:
댓글 달기