python多处理管理器列表错误:[Errno 2]没有这样的文件或目录

Question

我在python中编写了一个多处理程序.我用来multiprocessing.Manager().list()在子进程内共享列表.首先,我在主要过程中添加一些任务.然后,启动一些子进程来执行在共享列表中执行的任务,子进程还将任务添加到共享列表.但我有一个例外,如下:

    Traceback (most recent call last):
      File "/usr/lib64/python2.6/multiprocessing/process.py", line 232, in _bootstrap
        self.run()
      File "/usr/lib64/python2.6/multiprocessing/process.py", line 88, in run
        self._target(*self._args, **self._kwargs)
      File "gen_friendship.py", line 255, in worker
        if tmpu in nodes:
      File "<string>", line 2, in __contains__
      File "/usr/lib64/python2.6/multiprocessing/managers.py", line 722, in _callmethod
        self._connect()
      File "/usr/lib64/python2.6/multiprocessing/managers.py", line 709, in _connect
        conn = self._Client(self._token.address, authkey=self._authkey)
      File "/usr/lib64/python2.6/multiprocessing/connection.py", line 143, in Client
        c = SocketClient(address)
      File "/usr/lib64/python2.6/multiprocessing/connection.py", line 263, in SocketClient
        s.connect(address)
      File "<string>", line 1, in connect
    error: [Errno 2] No such file or directory

我找到一些有关如何使用共享列表蟒蛇多像这样.但仍然有一些例外.我不知道异常的含义.公共列表和manager.list之间有什么区别？

代码如下:

    nodes = multiprocessing.Manager().list()

    lock = multiprocessing.Lock()

    AMOUNT_OF_PROCESS = 10

    def worker():
        lock.acquire()
        nodes.append(node)
        lock.release()

    if __name__ == "__main__":

        for i in range(i):
            nodes.append({"name":"username", "group":1})

        processes = [None for i in range(AMOUNT_OF_PROCESS)]

        for i in range(AMOUNT_OF_PROCESS):
            processes[i] = multiprocessing.Process(taget=worker, args=())
            processes[i].start()

Answer 1

问题是您的主进程在启动所有工作进程后立即退出,这会关闭您的进程Manager.当您Manager关闭时,没有一个孩子可以使用您传递给他们的共享列表.您可以通过使用join等待所有孩子完成来修复它.在start调用之前,请确保您确实已经完成了所有流程join:

for i in range(AMOUNT_OF_PROCESS):
    processes[i] = multiprocessing.Process(taget=worker, args=())
    processes[i].start()
for process in processes:
    process.join()