2

这是一个奇怪的问题。我有 2 个不同的程序：服务器和客户端。

服务器启动，分配所有消息队列并开始等待来自客户端的信号（该信号用于告诉服务器“有新消息”）。服务器保持无限循环，直到收到 SIGQUIT。客户端在转换时开始向服务器发送大量消息

  for(;;){//infinite loop
    wait(sem,1); //wait for new message
    rc = msgctl(msgid, IPC_STAT, &qbuff); 
    seq_num++; 
    pid=fork(); //new process for take the message
    if(!pid){
            if((msgrcv(msgid, &q, msgsz, 1,MSG_NOERROR))== -1) 
                perror("msgrcv error");
            else{
                pthread_mutex_lock(&mutex); //start  critic sector
                printf("\nthere is a prenotation\n");
                q.price=get_conf_value(q.kindof_service)+(q.priority*get_conf_value(3)); //costo = costo_visita + (priorità * costo_priorità)
                q.turn=seq_num-q.priority; //assign turn
                pthread_mutex_unlock(&mutex); //end critic sector
                if(q.turn<0)q.turn=0; //controllo del turno che non sia minore di 0
                printf("---------------------------");
                printf("\nPrenotation number %i\npid caller: %i\npriorità: %i\n for %i\ncost %i\nturn %i\n",seq_num,q.clientId,q.priority, q.kindof_service ,q.price, q.turn);
                printf("---------------------------\nPrenotation ok\n\n\n");
                }
    printf("\nsuccess.\n");
    exit(1); //close children process
    }
    }

问题是，这样父亲留下了这么多丧尸。如果我添加

        else{//i am the father
        waitpid(pid, 0, 0);
    }

存在主进程fork，然后等到子进程结束，然后再fork的问题。我需要父亲分叉很多次，并且不要等到进程结束再分叉。

但是没有waitpid，问题是另一个问题。因为在那之后他开始接收所有消息所需的所有进程，父亲控制并仍然等待来自客户端的另一个信号（第一个 wait(sem,1) ），留下这么多僵尸进程。

我不知道我解释得好不好..英语很难-_-

所以，我想要一个服务器，接收到信号，分叉很多次。任何孩子接受信息并做一些事情，然后孩子结束。同时服务器继续等待新的传入消息。所有没有制造僵尸:)

4

1 回答 1

1

一种无需担心僵尸进程即可触发并忘记进程的方法是分叉两次。

每个进程都有一个父进程。如果父进程在子进程之前退出，则子进程将成为孤儿，并由init（进程 1）继承 - 这将等待所有子进程，防止他们在没有手动操作的情况下成为僵尸。

所以你可以做的是在子进程中分叉，然后再分叉。然后，您可以让孩子退出，这将导致孙子（您工作的地方）由init. 父进程可以wait为子进程（这不会花费很长时间，因为子进程除了分叉并退出之外什么也没做）。当孙子退出时，init将自动wait为它。

/* fire and forget */
int execute_detached(char **cmdline)
{
  pid_t pid;

  if((pid = fork()) < 0) { /* fork error */
    perror("fork");
    return 0;
  }
  else if(pid > 0) {       /* parent */
    waitpid(pid, NULL, 0);
    return 1;
  }
  else {                   /* child */
    if((pid = fork()) < 0) { /* fork error */
      perror("fork");
      return 0;
    }
    else if(pid > 0) {     /* child */
      /* make grand child an orphan */
      _exit(0);
    }
    else {                 /* grand child */
      execvp(cmdline[0], cmdline);
      perror("execvp");
      _exit(1);
    }
  }
  return 0;
}
于 2013-04-27T00:14:06.563 回答