Как корректно остановить Process в multiprocessing?

Question

[Northxstar]

Имеем простейшее использование модуля multiprocessing:

from multiprocessing import Process
pr=Process(target=MY_FUNCTION)
pr.start()

При попытки остановки этого чуда через pr.terminate() имеем:

...
pr.terminate()
print (pr.is_alive())
>>> True

Плюс к этому сохраняется PID и невозможно повторно запустить через pr.start()
Необходима возможность повторного запуска через .start() и способ определить текущий статус процесса, т.е. чтобы через .is_alive() было понятно, в каком он находится состоянии

Comments

[javedimka]

Добавь слипы на пол секунды и после этого вызывай is_alive()
Чтобы второй раз start() запустить создавай новый объект Process
Когда захочется чего-то посложнее, то почитай про очереди и сигналы

[Northxstar]

javedimka, ладно, новый Process создать можно. Но как тогда через is_alive() увидеть, что процесс был Terminate()? Слипы ставил, сам процесс выполнялся достаточно долго, но в is_alive() все равно TRUE. Может есть какой-то способ чистить список процессов?

[javedimka]

Northxstar,

>>> from multiprocessing import Process
>>> from time import sleep
>>> def my_func():
...  sleep(60)
...
>>> pr = Process(target=my_func)
>>> pr.start()
>>> pr.is_alive()
True
>>> pr.terminate()
>>> pr.is_alive()
False

Плохо слипы ставишь видимо

[Northxstar]

javedimka, действительно. Даже на тех слипах, что я ставил (5 секунд), работает правильно. Накосячил с импортом time. По второй части вопроса. Есть функция, в которую передается, например, "start" или "stop", и она должна, в зависимости от текущего состояния процесса запустить/остановить/"уже запущено"/"и так остановлено". Пример:

def myfunc_handler(COMMAND)
pr=Process(target=myfunc)
 if COMMAND == "start" and pr.is_alive==False
  pr.start()
 .....
......
......

Как ее привести в божеский вид? Нужно же тогда где-то хранить сам Process и либо обращаться к нему, либо создавать в него же новый. Глобально?

[Northxstar]

Northxstar, Вопрос закрыт:

def myfunc():
.....


pr = Process(target=myfunc)

def myfunc_handler(command):
 global pr
 if .....