8

我是 Python 新手，正在尝试使用 multiprocessing.pool 程序来处理文件，只要没有异常，它就可以正常工作。如果任何线程/进程出现异常，整个程序都会等待线程

代码片段：

cp = ConfigParser.ConfigParser()
cp.read(gdbini)
for table in cp.sections():
    jobs.append(table)
#print jobs
poolreturn = pool.map(worker, jobs)
pool.close()
pool.join()

失败消息：

Traceback (most recent call last):
  File "/opt/cnet-python/default-2.6/lib/python2.6/threading.py", line 525, in __bootstrap_inner
    self.run()
  File "/opt/cnet-python/default-2.6/lib/python2.6/threading.py", line 477, in run
    self.__target(*self.__args, **self.__kwargs)
  File "/opt/cnet-python/default-2.6/lib/python2.6/multiprocessing/pool.py", line 259, in _handle_results
    task = get()
TypeError: ('__init__() takes exactly 3 arguments (2 given)', <class 'ConfigParser.NoOptionError'>, ("No option 'inputfilename' in section: 'section-1'",))

我继续添加了一个异常处理程序来终止进程

try:
    ifile=cp.get(table,'inputfilename')
except ConfigParser.NoSectionError,ConfigParser.NoOptionError:
    usage("One of Parameter not found for"+ table)
    terminate()

但它仍在等待，不确定缺少什么。

4

2 回答 2

2

在 Python 3.2+ 中，这可以按预期工作。对于 Python 2，此错误已在 r74545 中修复，并将在 Python 2.7.3 中可用。同时，您可以使用该configparser库，它是 3.2+ 的 configparser 的后向端口。一探究竟。

于 2012-01-23T16:18:04.340 回答
0

我遇到过同样的问题。当工作进程引发具有自定义构造函数的用户异常时，就会发生这种情况。确保您的异常（在这种情况下为 ConfigParser.NoOptionError）使用两个参数初始化基本异常：

class NoOptionError(ValueError):

    def __init__(self, message, *args):
        super(NoOptionError, self).__init__(message, args)
于 2011-05-20T09:55:32.603 回答