摆脱僵尸进程答案

【问题标题】：Get rid of zombie processes摆脱僵尸进程
【发布时间】：2013-07-24 22:42:39
【问题描述】：

我无法摆脱一些僵尸进程。我已经阅读了有关此问题的其他一些答案，据我所知，当您的子进程未正确关闭时会发生这种情况。直到我在我的代码中添加了一个 while 循环，我才遇到这个问题。看看吧。

def worker(self):
    cmd = ["/home/orlando/CountMem","400000000","2000"]
    p = subprocess.Popen(cmd,stdout=subprocess.PIPE)
    id_list = []
    id_list.append(p.pid)



    while len(id_list) > 0:
         for num in id_list:
             stat_file = open("/proc/{0}/status".format(num))
             mem_dict = {}
             for i, line in enumerate(stat_file):
                 if i == 3:
                    #print line
                     mem_dict['ID'] = line
                     print(mem_dict)
                 if i == 10:
                    #print line
                     mem_dict['Mem'] = line
                     print(mem_dict)

    return id_list

if __name__ == '__main__':
    count = multiprocessing.cpu_count()
    pool = multiprocessing.Pool(processes = count)
    print(pool.map(worker,['ls']*count))

我的代码循环通过每个子进程的“/proc/PID/status”多次获取信息。如果没有“while”循环，它不会产生僵尸进程，但它也不能满足我想要它做的事情。通过循环，它可以完成我想要它做的事情，但它也会产生僵尸进程。我的问题是如何防止我的代码产生僵尸。以下是我得到的一些输出：

{'ID': 'Pid:\t2446\n'}                                                                                              
{'ID': 'Pid:\t2441\n'}                                                                                              
{'Mem': 'VmPeak:\t  936824 kB\n', 'ID': 'Pid:\t2446\n'}                                                             
{'Mem': 'VmPeak:\t  542360 kB\n', 'ID': 'Pid:\t2441\n'}                                                             
{'ID': 'Pid:\t2442\n'}                                                                                              
{'Mem': 'VmPeak:\t 1037580 kB\n', 'ID':

这会一直持续到子进程完成，然后它会立即开始打印：

{'ID': 'Pid:\t2602\n'}                                                                                              
{'ID': 'Pid:\t2607\n'}                                                                                              
{'ID': 'Pid:\t2606\n'}                                                                                              
{'ID': 'Pid:\t2604\n'}                                                                                              
{'ID': 'Pid:\t2605\n'}                                                                                              
{'Mem': 'Threads:\t1\n', 'ID': 'Pid:\t2606\n'}                                                                      
{'Mem': 'Threads:\t1\n', 'ID': 'Pid:\t2607\n'}                                                                      
{'Mem': 'Threads:\t1\n', 'ID': 'Pid:\t2605\n'}                                                                      
{'Mem': 'Threads:\t1\n', 'ID': 'Pid:\t2604\n'}

谁能帮我理解和解决正在发生的事情？

【问题讨论】：

这与孩子“没有正确关闭”无关。它与父母不回应死去的孩子有关。不要忽视你死去的孩子。这在生活和计算中都是有效的。
我同意，但这并不能帮助我理解我的代码有什么问题。
如果你得到僵尸，只有一个原因：父进程没有在等待子进程。在某些时候，您需要添加p.wait() 来清理僵尸。
我尝试在多个地方添加 p.wait() 。它要么清理僵尸进程，但阻止程序完成其最初的目的，否则它不会有任何效果。

标签： linux python-3.x subprocess zombie-process

【解决方案1】：

我想出了我需要添加的答案 p.poll() 我在while循环中添加了它。

def worker(self):
    cmd = ["/home/orlando/CountMem","400000000","2000"]
    p = subprocess.Popen(cmd,stdout=subprocess.PIPE)
    id_list = []
    id_list.append(p.pid)



    while len(id_list) > 0:
         for num in id_list:
             stat_file = open("/proc/{0}/status".format(num))
             mem_dict = {}
             for i, line in enumerate(stat_file):
                 if i == 3:
                    #print line
                     mem_dict['ID'] = line
                     print(mem_dict)
                 if i == 10:
                    #print line
                     mem_dict['Mem'] = line
                     print(mem_dict)
         p.poll()
    return id_list

if __name__ == '__main__':
    count = multiprocessing.cpu_count()
    pool = multiprocessing.Pool(processes = count)
    print(pool.map(worker,['ls']*count))

【讨论】：