多处理不起作用,挂在windows 10上的连接上

我对排队有疑问 multiprocessing python 3中的模块

这就是他们在 programming guidelines :

请记住,将项目放入队列的进程将在之前等待 终止,直到所有缓冲的项目都由“进料器”线程送入 下面的管道。(子进程可以调用 排队取消_连接_线程 队列的方法来避免这种行为。)

这意味着,无论何时使用队列,都需要确保所有 已放入队列的项目最终将在 过程被加入。否则,您无法确定哪些流程 将项目放入队列将终止。还要记住,非守护进程 进程将自动加入。

死锁的示例如下:

from multiprocessing import Process, Queue

def f(q):
    q.put('X' * 1000000)

if __name__ == '__main__':
    queue = Queue()
    p = Process(target=f, args=(queue,))
    p.start()
    p.join()                    # this deadlocks
    obj = queue.get()

这里的一个修复方法是交换最后两行(或者简单地删除 p.join()行)。

所以很明显, queue.get() 不应该在a之后被调用 join() .

然而,也有使用队列的例子,其中 get 在a之后被调用 join 比如:

import multiprocessing as mp
import random
import string

# define a example function
def rand_string(length, output):
    """ Generates a random string of numbers, lower- and uppercase chars. """
    rand_str = ''.join(random.choice(
                string.ascii_lowercase
                + string.ascii_uppercase
                + string.digits)
    for i in range(length))
        output.put(rand_str)

 if __name__ == "__main__":
     # Define an output queue
     output = mp.Queue()

     # Setup a list of processes that we want to run
     processes = [mp.Process(target=rand_string, args=(5, output))
                    for x in range(2)]

     # Run processes
    for p in processes:
        p.start()

    # Exit the completed processes
    for p in processes:
        p.join()

    # Get process results from the output queue
    results = [output.get() for p in processes]

    print(results)

我已经运行了这个程序,它是有效的(也作为StackOverFlow问题的解决方案发布) Python 3 - Multiprocessing - Queue.get() does not respond ).

有人能帮我理解僵局的规则是什么吗?