Python多处理atexit错误"atexit._run_exitfuncs错误"; [英] Python Multiprocessing atexit Error "Error in atexit._run_exitfuncs"
问题描述
我正在尝试在Python中运行一个简单的多进程应用程序.主线程产生1到N个进程,并等待直到它们全部完成处理为止.每个进程都运行一个无限循环,因此它们有可能永远运行而不会受到用户的干扰,因此我放入了一些代码来处理KeyboardInterrupt:
I am trying to run a simple multiple processes application in Python. The main thread spawns 1 to N processes and waits until they all done processing. The processes each run an infinite loop, so they can potentially run forever without some user interruption, so I put in some code to handle a KeyboardInterrupt:
#!/usr/bin/env python
import sys
import time
from multiprocessing import Process
def main():
# Set up inputs..
# Spawn processes
Proc( 1).start()
Proc( 2).start()
class Proc ( Process ):
def __init__ ( self, procNum):
self.id = procNum
Process.__init__(self)
def run ( self ):
doneWork = False
while True:
try:
# Do work...
time.sleep(1)
sys.stdout.write('.')
if doneWork:
print "PROC#" + str(self.id) + " Done."
break
except KeyboardInterrupt:
print "User aborted."
sys.exit()
# Main Entry
if __name__=="__main__":
main()
问题是,使用CTRL-C退出时,即使进程似乎立即退出,我也会收到另一个错误:
The problem is that when using CTRL-C to exit, I get an additional error even though the processes seem to exit immediately:
......User aborted.
Error in atexit._run_exitfuncs:
Traceback (most recent call last):
File "C:\Python26\lib\atexit.py", line 24, in _run_exitfuncs
func(*targs, **kargs)
File "C:\Python26\lib\multiprocessing\util.py", line 281, in _exit_function
p.join()
File "C:\Python26\lib\multiprocessing\process.py", line 119, in join
res = self._popen.wait(timeout)
File "C:\Python26\lib\multiprocessing\forking.py", line 259, in wait
res = _subprocess.WaitForSingleObject(int(self._handle), msecs)
KeyboardInterrupt
Error in sys.exitfunc:
Traceback (most recent call last):
File "C:\Python26\lib\atexit.py", line 24, in _run_exitfuncs
func(*targs, **kargs)
File "C:\Python26\lib\multiprocessing\util.py", line 281, in _exit_function
p.join()
File "C:\Python26\lib\multiprocessing\process.py", line 119, in join
res = self._popen.wait(timeout)
File "C:\Python26\lib\multiprocessing\forking.py", line 259, in wait
res = _subprocess.WaitForSingleObject(int(self._handle), msecs)
KeyboardInterrupt
我正在Windows上运行Python 2.6.如果有更好的方法来处理Python中的多重处理,请告诉我.
I am running Python 2.6 on Windows. If there is a better way to handle multiprocessing in Python, please let me know.
推荐答案
您不是要强制sys.exit()
,而是要向线程发送信号以告诉它们停止.研究使用信号处理程序和Python中的线程.
Rather then just forcing sys.exit()
, you want to send a signal to your threads to tell them to stop. Look into using signal handlers and threads in Python.
您可以通过将while True:
循环更改为while keep_processing:
来实现此目的,其中keep_processing
是某种在KeyboardInterrupt异常上设置的全局变量.我认为这不是一个好习惯.
You could potentially do this by changing your while True:
loop to be while keep_processing:
where keep_processing
is some sort of global variable that gets set on the KeyboardInterrupt exception. I don't think this is a good practice though.
这篇关于Python多处理atexit错误"atexit._run_exitfuncs错误";的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!