Linux 下 multiprocessing 的结束子进程问题

[smallgoogle]

# -*- coding:utf-8 -*-
import time
import multiprocessing



# 主进程
def Start(num):
    while True:
        print(">>>>>>>> 我是第 " + str(num) + " 个子线程！")
        time.sleep(20)


if __name__ == '__main__':
        # 创建子进程让定时器多进程同步运行
        i = 0
        while i < 4:
            print("创建第 " + str(i) + " 子进程！")
            t = multiprocessing.Process(target=Start, args=(i,))
            t.start()
            i = i + 1
            time.sleep(5)  # 给个延时，避免子线程启动太快导致的错误

我有一个问题就是，这样创建子进程，然后我如何在 linux 下 kill 掉主进程的 pid 之后，子进程都能结束呢？
我百度了很多文章，都没看明白人家写的意思；
所以看看大神是否能解答一下，我大概在什么位置需要加个什么东西来处理？

[mahone3297]

kill 主进程，子进程的父进程，应该是直接变成 init(pid 1)

[lolizeppelin]

不要老盯着 python
好好把 linux fork wait 信号部分学一下
你这些问题光在 python 里是解答不了的

[www5070504]

linux 里父进程结束 子进程不一定结束啊 信号处理都是单独的 你可以试试在父进程添加信号处理函数 接收到某个信号的时候就杀死全部子进程然后父进程自己退出 这样应该可以

[tomcat65535]

https://docs.python.org/3.6/library/signal.html
你需要一个 singal handler，

import singal

类似于

def int_singnal_handler(signum, frame):
pass # do something to end your processes

# blah blah blah

signal.signal(signal.SIGINT, int_signal_handler)

[julyclyde]

嗯
这问题简直太经典了
“单看问题”就能得出没好好读书的结论

[smallgoogle]

@julyclyde 不要酱紫。

[claymore94]

怎么输出里又有线程？

在 t.start() 前设置：t.daemon=True

[lolizeppelin]

比较好的做法就是

父进程开一个管道

子进程开一个线程去阻塞读这个管道, 一旦读到就 os._exit

[firebroo]

4 楼√

[smallgoogle]

@tomcat65535 你这个方法是可行的。可是发现一个问题。如果 TTY 是一个问号。。就是假如这个脚本是由另外一个脚本发起运行的。tty 就会变成问号。然后 os.killpg 就会报错不存在这个进程。

[ooeyunarika]

4 楼√

[fengjianxinghun]

man fork

* The prctl(2) PR_SET_PDEATHSIG setting is reset so that the child does not receive a signal when its parent terminates.

[tomcat65535]

@smallgoogle
845 是 pid 啊
os.killpg(os.getpgid(p.pid), signal.SIGKILL)
=========================
os.killpg(pgid, sig)
Send the signal sig to the process group pgid.
--------------------------------
os.kill(pid, sig)
Send signal sig to the process pid. Constants for the specific signals available on the host platform are defined in the signal module.

[fanhaipeng0403]

t.daeman =true
老大做完，小弟就不做了

t.join()
老大等小弟做完继续在做


class CountdownTask:
def __init__(self):
self._running = True

def terminate(self):
self._running = False

def run(self, n):
while self._running and n > 0:
print('T-minus', n)
n -= 1
time.sleep(5)

c = CountdownTask()
t = multiprocessing.Process(target=c.run, args=(10,))
t.start()
c.terminate() # Signal termination
t.join() # Wait for actual termination (if needed)
老大给小弟给信号



不知道理解的对不对、、、

[fanhaipeng0403]

```
class CountdownTask:
def __init__(self):
self._running = True

def terminate(self):
self._running = False

def run(self, n):
while self._running and n > 0:
print('T-minus', n)
n -= 1
time.sleep(5)

c = CountdownTask()
t = Thread(target=c.run, args=(10,))
t.start()
c.terminate() # Signal termination
t.join() # Wait for actual termination (if needed)
```