如何将 pid 的值保存在数据结构中并稍后使用 fork() 访问它？

Question

我有一个程序，我正在创建几个不同的子进程来模拟 shell 脚本。如果进程应该在后台运行，我正在做的是创建一个子进程，然后将它的进程 ID 存储在数据库中，以便下次我运行命令时，我可以进行快速检查with waitpid(pid,status,WNOHANG).

我运行遇到的问题是存储子进程 ID 的值，然后尝试访问它们。

这是我创建新子进程并将它们插入接受 void * 作为“节点”的 DLL 的代码：

typedef void*Data;

extern void execCommand(Command command, Pipeline pipeline, Jobs jobs,
                             int *jobbed, int *eof, int fg) {
  CommandRep r=command;
  if (fg && builtin(r,eof,jobs))
    return;

  int pid=fork();
  if (pid==-1)
    ERROR("fork() failed");
  if (pid==0){
    // do some work as the child
  } else if(fg && pid > 0) {
    // if you're a parent and this is a foreground process
    // wait for the most recent process that started running
    // then try to wait for existing children if they exist
    int c_stat = -999;
    waitpid(pid,&c_stat,0);
    attemptWait();
  } else if (fg==0 && pid > 0) {
    // if you're a parent and this is a background process
    // add this childs process id to the list, and then
    // attempt to wait for all processes to finish
    dll_put(running_processes,(Data)&pid);
    attemptWait();
  }
}

void attemptWait() {
  int j=-999;
  for(int i=0;i<dll_len(running_processes);i++) {
    j=waitpid(*(int *)dll_ith(running_processes, i),&j,WNOHANG);
    printf("child pid: %d\n",*(int *)dll_ith(running_processes, i));
    if((j)==(*(int *)dll_ith(running_processes, i))) {
      printf("[%d]+ Done", i);
    } else if (j == -1) {
      printf("there was an error closing the %d-th process\n", i);
    }
  }
}

现在发生的事情是，当我存储新创建的子进程的 pid 时，我将 pid 的地址传递给它以存储在数据结构中，但是下一次调用 execCommand 时，pid 被更新，所以我在 DLL 中的所有 pids 都被覆盖，每次我输入命令时我都试图关闭相同的进程。

如何只获取存储在 DLL 中的整数值，以便我可以使用它而不用担心它会被覆盖？

Answer 1

我不知道你正在使用的 dll_..() 函数，但显然你总是存储一个局部变量的地址，当 execFunction() returns .所以你应该尝试分配一个缓冲区来存储那个 pid:

pid_t *pid_ptr = malloc( sizeof *pid_ptr );
*pid_ptr = pid;
dll_put(running_processes, pid_ptr);

并且不要忘记在您不再需要该 pid 时调用 free()（应该在子进程终止之后）

如何将 pid 的值保存在数据结构中并稍后使用 fork() 访问它？

How can I save the value of pid in a data structure and access it later with fork()?

c

parallel-processing

fork

multiprocessing

child-process