Python多进程库：使用导入的包时出现NameError

Question

以下代码完美运行：

from multiprocessing import Pool
import time

values = list(range(10))

def print_time_and_value(value):
    print(time.time(), value)

if __name__ == '__main__':

    p = Pool(4)
    p.map(print_time_and_value, values)

但是当我将“multiprocessing”导入更改为"multiprocess"库时：

from multiprocess import Pool

它在执行期间引发以下错误：

Traceback (most recent call last):
  File "test.py", line 13, in <module>
    p.map(print_time_and_value, values)
  File "C:\Users\User\Anaconda3_64bits\lib\site-packages\multiprocess\pool.py", line 268, in map
    return self._map_async(func, iterable, mapstar, chunksize).get()
  File "C:\Users\User\Anaconda3_64bits\lib\site-packages\multiprocess\pool.py", line 657, in get
    raise self._value
NameError: name 'time' is not defined

我不能使用多处理，因为我必须稍后在我的主应用程序上使用不可销售的对象，所以我必须使用具有莳萝序列化的多进程。

我注意到将“time”导入到“print_time_and_value”函数而不是全局作用域中解决了这个问题，但这种行为有点奇怪。由于它是多处理的分支，我猜想它会以同样的方式工作。

我使用的是Python 3.7.0，多进程模块的版本是0.70.7;运行在64位Anaconda环境，Windows 10。

Answer 1

我是multiprocess的作者。我看到你在Windows上...当你在Windows上运行时，我建议你使用freeze_support。我相信应该解决你所看到的NameError。

import multiprocess as mp
import time

values = list(range(10))

def print_time_and_value(value):
    print(time.time(), value)


if __name__ == '__main__':

    mp.freeze_support()  # needed for Windows
    p = mp.Pool(4)
    p.map(print_time_and_value, values)

使用multiprocess，您的代码甚至应该在解释器中工作：

Python 3.7.3 (default, Mar 30 2019, 05:40:15) 
[Clang 9.0.0 (clang-900.0.39.2)] on darwin
Type "help", "copyright", "credits" or "license" for more information.
>>> 
>>> import multiprocess as mp
>>> import time
>>> values = list(range(10))
>>> def print_time_and_value(value):
...     print(time.time(), value)
... 
>>> p = mp.Pool(4)
>>> _ = p.map(print_time_and_value, values)
1556681189.844021 0
1556681189.8443708 1
1556681189.8446798 2
1556681189.845576 4
1556681189.84569 5
1556681189.8458931 3
1556681189.846055 6
1556681189.846396 7
1556681189.846845 8
1556681189.847295 9
>>> 

请注意，我通常会在函数中包含import time，因为它使序列化更容易。