Проблема следующая: есть два потока один создает (создатель) задачи (процессы), второй их при определенных условиях должен убивать (киллер).
Для передачи информации используется общий словарь dict() в которой создатель пишет процессы, а киллер запускает для заданного dict["PROC_TO_KILL"].terminate
Вопрос следующий, при вызове этой функции terminate
процессы продолжают отображаться "зомби процессы Z", как окончательно убить процесс?
И подвопрос: как сделать рекурсивное удаление всех процессов которые были порождены этим процессом (или это будет сделано автоматически)?
!Нюанс: в режиме отладки код работает нормально, процесс убиваются без появления "зомбарей".
Свои варианты закомментированы в коде киллера, они либо не работают либо дают тот же вариант.
Main
def Main():
table_proc = dict() # таблица процессов
lock = Lock()
# создание классов-потоков
creator = Creator(... lock, table_proc)
creator.start() # запуск создателя
killer = Killer(...lock, table_proc)
killer.start() # запуск киллера
creator.join() # main() ждет смерти этого потока
killer.join() # main() ждет смерти и этого потока
# Тестовая функция процесс порождаемый создателем
def New_Func(name):
while True:
print("I'm %s my PID: %i") % (name, os.getpid())
time.sleep(2)
print "NO MORE "
if __name__ == '__main__':
Main() # начало программы
В создателе потоков:
def create_proc(self, body):
p = Process(target=New_Func, args=(body["name"],))
self.lock.acquire()
try:
self.table_proc[body["name"]] = p
except Exception as inst1:
print(inst) #обработка исключения
self.lock.release()
return False
pass
finally:
self.lock.release()
p.daemon = True
p.start()
return True
В киллере:
def kill(self, body):
self.lock.acquire()
try:
self.table_proc[body["name"]].terminate() из таблицы
#os.kill(self.table_proc[body["name"]].pid, 9)
#os.kill(self.table_proc[body["name"]].pid, os.SIGTERM)
#os.killpg(os.getpgid(self.table_proc[body["name"]]), os.SIGTERM)
#todo УДАЛИТЬ из таблицы задач
except Exception as inst1:
print(inst1)
self.lock.release
return False
pass
finally:
self.lock.release()
return True