我有一个系统,需要从几个不同的进程接收输入。最简单的只是命令行,用户可以在其中手动输入数据。这些数据将添加到multiprocessing.Queue并由主流程稍后处理,但我还没有走那么远;raw_input在进程内部调用似乎不起作用。我抽出了代码的精髓,下面是一个示例:
multiprocessing.Queue
raw_input
import multiprocessing def f(): while True: raw_input('>>>') p = multiprocessing.Process(target = f) p.start()
这个简单的代码抛出了这一点:
~$ python test.py Process Process-1: Traceback (most recent call last): File "/usr/lib/python2.6/multiprocessing/process.py", line 232, in _bootstrap self.run() File "/usr/lib/python2.6/multiprocessing/process.py", line 88, in run self._target(*self._args, **self._kwargs) File "test.py", line 5, in f raw_input('>>>') EOFError: EOF when reading a line >>>~$
如何在Python的进程中获取命令行输入?
当您在Python中生成线程时,它将关闭stdin。您不能使用子流程来收集标准输入。使用主线程来收集输入,然后将其从主线程发布到队列中。可以将stdin传递到另一个线程,但是您可能需要在主线程中将其关闭。