如何确保子进程不会在父进程终止时终止？答案

【问题标题】：How to make sure the child process does not terminate when the parent does?如何确保子进程不会在父进程终止时终止？
【发布时间】：2018-03-11 23:56:31
【问题描述】：

我有一个父进程在一个类中运行一个子进程。子进程需要更长的时间才能完成。我想确保父进程终止时子进程不会终止。我该怎么做？

这是我的代码的一个非常简化的版本：

# myClass.py
from multiprocess import Process
class myClass(self):
    def __init__(self):
        print ('setup the object')
    def parentProcess(self, idx)
        p = Process(target=childFunc)
        p.start()
        time.sleep(3)
        print ('parent is done with ' + str(idx))
    def childProcess(self):
        print ('do some childish stuff')
        time.sleep(8)

这就是我运行父进程的方式

# main.py
from multiprocessing import Process
myClass import myClass
myC = myClass()
for i in range(10):
    p = Process(target=myC.parentProcess, args=i)
    p.start()
    p.join()

【问题讨论】：

您使用哪种操作系统？
@tdelaney Ubuntu
从我的头顶开始：fork 两次，更改 pgroup，从终端分离，阅读 Stevens 的 APUE
@wildplasser 对不起，我对多处理有点陌生，不明白你所说的任何这些事情。能说清楚一点吗？
通常，父进程应该管理它的子进程，或者子进程应该能够完全独立于父进程来处理自己（这是@wildplasser 的建议）。双叉子将子节点从控制台会话中取出并归 init 所有，它将处理它的僵尸状态。

标签： python ubuntu parent-child python-multiprocessing child-process

【解决方案1】：

在所有进程完成之前，您的程序不会终止。试试这个：

from multiprocessing import Process

import time


def foo():
    time.sleep(2)
    print("Now I am done")


if __name__ == "__main__":
    p = Process(target=foo)
    p.start()
    print("I am done.")

但是，要控制流程的执行：

使用child.join() 等待子进程结束。
您应该使用两个循环，一个用于启动进程，一个用于加入它们

试试这个：

from multiprocessing import Process

import time


class MyClass():
    def __init__(self, idx):
        self.idx = idx

    def start_parent(self):
        p = Process(target=self.child_func)
        p.start()
        time.sleep(1)
        print('parent is done, waiting for child', self.idx)
        p.join()
        print('parent exiting', self.idx)

    def child_func(self):
        print('child start', self.idx)
        time.sleep(2)
        print('child end', self.idx)

if __name__ == "__main__":
    parents = []
    for i in range(10):
        o = MyClass(i)
        p = Process(target=o.start_parent)
        parents.append(p)
        p.start()

    for p in parents:
        p.join()

    print("all done")

或者更好，继承Process并实现run()：

from multiprocessing import Process

import time


class ParentProcess(Process):
    def __init__(self, idx, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.idx = idx

    def run(self):
        print('parent start', self.idx)
        child = ChildProcess(self)
        child.start()
        time.sleep(1)
        print('waiting for child', self.idx)
        child.join()
        print('parent end', self.idx)


class ChildProcess(Process):
    def __init__(self, parent, *args, **kwargs):
        super().__init__(*args, **kwargs)
        self.parent = parent

    def run(self):
        print('child start', self.parent.idx)
        time.sleep(5)
        print('child end', self.parent.idx)


if __name__ == "__main__":
    parents = [ParentProcess(i) for i in range(10)]
    for p in parents:
        p.start()

    for p in parents:
        p.join()

    print("all done")

【讨论】：