2

我想同时运行 2 个进程。1 将保持每秒打印“a”，另一个将要求输入，当输入为“Y”时，第一个进程将停止打印“a”。我对Python相当陌生，我无法弄清楚......

到目前为止，这是我想出的：

from multiprocessing import Process
import time

go = True

def loop_a():
    global go

    while go == True:
        time.sleep(1)
        print("a")

def loop_b():
    global go
    text = input('Y/N?')

    if text == 'Y':
        go = False

if __name__ == '__main__':
    Process(target=loop_a).start()
    Process(target=loop_b).start()

这是我收到的错误消息：

Process Process-2:
Traceback (most recent call last):
  File "C:\Users\Tip\AppData\Local\Programs\Python\Python36\lib\multiprocessing\process.py", line 249, in _bootstrap
    self.run()
  File "C:\Users\Tip\AppData\Local\Programs\Python\Python36\lib\multiprocessing\process.py", line 93, in run
    self._target(*self._args, **self._kwargs)
  File "F:\ProgrammingTK\PROGproject\test.py", line 15, in loop_b
    text = input('Y/N?')
EOFError: EOF when reading a line
4

1 回答 1

0

扩展jasonharper他的评论，因为他是正确的。

有几个问题

  1. 该go变量不在进程之间共享。正如 Jason 建议的那样，您可以使用类似Managerin的东西multiprocessing来在多个进程之间共享一个值。从技术上讲，该go变量将被复制到每个进程中，但不会在它们之间共享，因此一个进程中的更改不会被另一个进程看到。
  2. 同样，正如他所提到的，您需要将其拉input(..)入程序的主线程。此外，如果您使用的是 2.7，则需要使用raw_input(..).
  3. 此外，如果您只检查一次标志然后退出，那么您可能会遇到BrokenPipeError.

考虑到这一点，你可以尝试这样的事情：

from multiprocessing import Process, Manager
import time


def loop_a(go):
    while True:
        # run forever and print out the msg if the flag is set
        time.sleep(1)
        if go.value:
            print("a")

if __name__ == '__main__':
    # shared value flag
    manager = Manager()
    go_flag = manager.Value('flag', True)

    # other process that is printing
    Process(target=loop_a, args=(go_flag,)).start()

    # normal main thread; toggle on and off the other process
    while True:
        text = input('Stop Y/N?')
        if text == 'Y':
            go_flag.value = False
            print("Changed the flag {}".format(go_flag.value))
        else:
            go_flag.value = True
            print("Changed the flag {}".format(go_flag.value))
于 2017-11-06T21:55:16.833 回答