현재 위치

홈 ›› Forums ›› 공부 ›› 프로그래밍 QnA

fork와 pipe를 사용해서 순환하는 작업

andylhw의 이미지
글쓴이: 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: 
프로그래밍 QnA

둘러보기