Spyder中的简单Python多重处理功能不会输出结果

Question

我在这里有一个非常简单的函数，试图在其中运行和测试，但是它不输出任何东西，也没有任何错误。我已经多次检查代码，但没有任何错误。

我打印了工作，这是我得到的：

[<Process(Process-12, stopped[1])>, 
<Process(Process-13, stopped[1])>,
<Process(Process-14, stopped[1])>, 
<Process(Process-15, stopped[1])>,
<Process(Process-16, stopped[1])>]

这是代码：

import multiprocessing

def worker(num):
    print "worker ", num
    return

jobs = []
for i in range(5):
    p = multiprocessing.Process(target = worker, args = (i,))
    jobs.append(p)
    p.start()

这是我期望的结果，但未输出任何内容：

Worker: 0
Worker: 1
Worker: 2
Worker: 3
Worker: 4

Answer 1

评论显示OP和Spyder都使用Windows。由于Spyder重定向stdout并且Windows不支持分支，因此新的子进程将不会打印到Spyder控制台中。这完全是由于stdout新的子进程是Python的香草标准输出，也可以在中找到sys.__stdout__。

有两种选择：

1. 使用日志记录模块。这将包括创建所有消息并将其记录到一个或几个文件中。使用单个日志文件可能会导致以下问题：由于进程将同时写入文件，因此输出会出现一些乱码。每个进程使用一个文件可以解决此问题。

2. 不在print子进程中使用，而只是将结果返回给主进程。通过使用队列（或multiprocessing.Manager().Queue()因为不可能进行分叉）或更简单地依靠多处理池的 map功能，请参见下面的示例。

带有池的多处理示例：

import multiprocessing

def worker(num):
    """Returns the string of interest"""
    return "worker %d" % num

def main():
    pool = multiprocessing.Pool(4)
    results = pool.map(worker, range(10))

    pool.close()
    pool.join()

    for result in results:
        # prints the result string in the main process
        print(result)

if __name__ == '__main__':
    # Better protect your main function when you use multiprocessing
    main()

哪个打印（在主要过程中）

worker 0
worker 1
worker 2
worker 3
worker 4
worker 5
worker 6
worker 7
worker 8
worker 9

编辑：如果您不耐烦地等待map函数完成，则可以通过使用imap_unordered命令并稍微更改命令的顺序来立即打印结果：

def main():
    pool = multiprocessing.Pool(4)
    results = pool.imap_unordered(worker, range(10))

    for result in results:
        # prints the result string in the main process as soon as say are ready
        # but results are now no longer in order!
        print(result)

    # The pool should join after printing all results
    pool.close()
    pool.join()