控制运行Python进程（多处理）

Question

我还有一个关于Python多处理的问题。我有一个模块，它创建了一个进程，并在while-True循环中运行。此模块将从另一个Python模块启用/禁用。另一个模块将导入第一个模块一次，并作为进程运行。

我该如何更好地实现这一点？

因此，作为参考：

#foo.py

def foo():
  while True:
    if enabled:
      #do something

p = Process(target=foo)
p.start()

想象第二个模块是这样的：

#bar.py
import foo, time

def bar():
  while True:
    foo.enable()
    time.sleep(10)
    foo.disable()

Process(target=bar).start()

不断地运行一个流程来检查循环中的条件似乎是一种浪费，但我很乐意接受这样的解决方案，它只允许我从外部设置enabled值。理想情况下，我希望能够终止并重新启动流程，再次从该模块外部开始。据我所知，我将使用队列向进程传递命令。如果确实是这样，有人能告诉我如何设置它，我可以从不同的模块向队列添加一些东西吗。

这甚至可以用Python轻松完成吗，或者是时候放弃希望，切换到像C或Java

Answer 1

我在评论中提出了两种不同的方法：

• 使用来自的共享变量。值
• 用信号暂停/恢复进程

def target_process_1(run_statement):
    while True:
        if run_statement.value:
            print "I'm running !"
            time.sleep(1)

def target_process_2(run_statement):
    time.sleep(3)
    print "Stoping"
    run_statement.value = False
    time.sleep(3)
    print "Resuming"
    run_statement.value = True

if __name__ == "__main__":
    run_statement = Value("i", 1)

    process_1 = Process(target=target_process_1, args=(run_statement,))
    process_2 = Process(target=target_process_2, args=(run_statement,))

    process_1.start()
    process_2.start()

    time.sleep(8)
    process_1.terminate()
    process_2.terminate()

from multiprocessing import Process
import time
import os, signal

def target_process_1():
    while True:
        print "Running !"
        time.sleep(1)

def target_process_2(target_pid):
    time.sleep(3)
    os.kill(target_pid, signal.SIGSTOP)
    time.sleep(3)
    os.kill(target_pid, signal.SIGCONT)

if __name__ == "__main__":
    process_1 = Process(target=target_process_1)
    process_1.start()

    process_2 = Process(target=target_process_2, args=(process_1.pid,))
    process_2.start()

    time.sleep(8)

    process_1.terminate()
    process_2.terminate()

旁注：如果可能，在为True时不要运行。

编辑：如果您想在两个不同的文件中管理流程，假设您想通过共享变量来使用控件，这是一种方法。

# file foo.py

from multiprocessing import Value, Process
import time

__all__ = ['start', 'stop', 'pause', 'resume']

_statement = None
_process = None

def _target(run_statement):
    """ Target of the foo's process """
    while True:
        if run_statement.value:
            print "I'm running !"
            time.sleep(1)

def start():
    global _process, _statement
    _statement = Value("i", 1)
    _process = Process(target=_target,  args=(_statement,))
    _process.start()

def stop():
    global _process, _statement
    _process.terminate()
    _statement, _process = None, _process

def enable():
    _statement.value = True

def disable():
    _statement.value = False