Python中两个多进程之间共享列表

Question

我正在学习如何在 Python 中使用 multiprocessing 模块，并按照在线教程尝试我自己的代码。这是我的代码，

import multiprocessing as mp
import time

manager = mp.Manager()

def update_array_list(datalist):
    for i in range(1,10):
        datalist.append(i)
        print(f"loading list array with {i} elements : {datalist}")
        print("_________________________________________")
        time.sleep(2)

def display_array_list(datalist):
    while True:
        print(f"Items in array {datalist} ")
        time.sleep(1)

if __name__ == '__main__':   
    datalist = manager.list()
    datalist.clear()

    l1 = mp.Process(target=update_array_list,args=(datalist))
    l2 = mp.Process(target=display_array_list,args=(datalist))

    l1.start()
    l2.start()
    l1.join()
    l2.join()

我的 l1 进程以两秒的间隔更新共享列表 datalist，而我的 l2 进程以 1 秒的间隔打印它们。

我的代码无法运行，尽管这与教程几乎相同。

我收到以下错误。

...............
    _check_not_importing_main()
  File "C:\Users\pgooneti\Anaconda3\envs\NOUS\lib\multiprocessing\spawn.py", line 136, in _check_not_importing_main
    is not going to be frozen to produce an executable.''')
RuntimeError:
        An attempt has been made to start a new process before the
        current process has finished its bootstrapping phase.

        This probably means that you are not using fork to start your
        child processes and you have forgotten to use the proper idiom
        in the main module:

            if __name__ == '__main__':
                freeze_support()
                ...

        The "freeze_support()" line can be omitted if the program
        is not going to be frozen to produce an executable.

这里有什么错误？

Answer 1

在 ms-windows 和 macOS 上，多处理附带了一些额外的编程指南。

由于多处理必须在这些平台上工作，因此您的脚本必须可安全导入。
这意味着在 if __name__ == "__main__": 块之外，理想情况下应该只具有导入、函数和类定义。

而且您当然不应该尝试在该块之外实例化任何 multiprocessing.Process、multiprocessing.Pool、multiprocessing.Manager 类！

考虑一下当您在 "__main__" 块之外创建一个 Process 时会发生什么：

1. 您启动运行脚本的 Python。
2. 您启动一个 Process
3. Python 启动一个新的 Python 解释器，它会导入您的脚本。
4. 这将返回到步骤 2。

如果不选中，这将用 Python 进程填满您的计算机内存。因此出现了运行时错误。

Answer 2

您的代码没问题，只需注意 文档 因为参数应该是一个元组而不是一个 list()

尝试改变这一行（注意参数后面的逗号）：

l1 = mp.Process(target=update_array_list,args=(datalist,))
l2 = mp.Process(target=display_array_list,args=(datalist,))

$ python3 multi.py
loading list array with 1 elements : [1]
_________________________________________
Items in array [1] 
Items in array [1] 
Items in array [1, 2] 
loading list array with 2 elements : [1, 2]
_________________________________________
Items in array [1, 2] 
Items in array [1, 2, 3] 
loading list array with 3 elements : [1, 2, 3]
_________________________________________
Items in array [1, 2, 3] 
Items in array [1, 2, 3, 4] 
loading list array with 4 elements : [1, 2, 3, 4]
_________________________________________
Items in array [1, 2, 3, 4] 
Items in array [1, 2, 3, 4] 
loading list array with 5 elements : [1, 2, 3, 4, 5]
_________________________________________