如何杀死多处理模块创建的僵尸进程？
如何杀死多处理模块创建的僵尸进程？
提问于 2013-10-11 23:42:24
我对multiprocessing模块非常陌生。我刚刚尝试创建以下内容:我有一个进程，它的任务是从RabbitMQ获取消息并将其传递到内部队列(multiprocessing.Queue)。然后，我想要做的是:在新消息传入时生成一个进程。它可以工作，但在作业完成后，它会留下一个未被其父进程终止的僵尸进程。下面是我的代码：
主要进程：
#!/usr/bin/env python
import multiprocessing
import logging
import consumer
import producer
import worker
import time
import base
conf = base.get_settings()
logger = base.logger(identity='launcher')
request_order_q = multiprocessing.Queue()
result_order_q = multiprocessing.Queue()
request_status_q = multiprocessing.Queue()
result_status_q = multiprocessing.Queue()
CONSUMER_KEYS = [{'queue':'product.order',
'routing_key':'product.order',
'internal_q':request_order_q}]
# {'queue':'product.status',
# 'routing_key':'product.status',
# 'internal_q':request_status_q}]
def main():
# Launch consumers
for key in CONSUMER_KEYS:
cons = consumer.RabbitConsumer(rabbit_q=key['queue'],
routing_key=key['routing_key'],
internal_q=key['internal_q'])
cons.start()
# Check reques_order_q if not empty spaw a process and process message
while True:
time.sleep(0.5)
if not request_order_q.empty():
handler = worker.Worker(request_order_q.get())
logger.info('Launching Worker')
handler.start()
if __name__ == "__main__":
main()这是我的工人：
import multiprocessing
import sys
import time
import base
conf = base.get_settings()
logger = base.logger(identity='worker')
class Worker(multiprocessing.Process):
def __init__(self, msg):
super(Worker, self).__init__()
self.msg = msg
self.daemon = True
def run(self):
logger.info('%s' % self.msg)
time.sleep(10)
sys.exit(1)因此，在处理完所有消息之后，我可以使用ps aux命令查看进程。但我真的希望他们一旦完成就被终止。谢谢。
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/19322129
复制相关文章
相似问题