使用多处理没有来自 Process 的输出

Question

我是多处理的初学者，谁能告诉我为什么这不会产生任何输出？

import multiprocessing

def worker(num):
    """thread worker function"""

    print('Worker:', num)

if __name__ == '__main__':
    jobs = []

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

Answer 1

您正在启动您的Process()，但从不等待它完成，因此您的程序执行在后台进程完成之前结束。试试这个，打电话给Process.join()：

import multiprocessing
import sys

def worker(num):
    """thread worker function"""

    print('Worker:', num)
    sys.stdout.flush()

if __name__ == '__main__':
    jobs = []

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

    map(lambda p: p.join(), jobs)

这里我们使用map() 对jobs 列表中的每个进程调用join()。

这是一个工作示例：

In [127]: %paste
import multiprocessing
import sys

def worker(num):
    """thread worker function"""

    print('Worker:', num)
    sys.stdout.flush()

if __name__ == '__main__':
    jobs = []

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

    map(lambda p: p.join(), jobs)

## -- End pasted text --
Worker: 2
Worker: 1
Worker: 0
Worker: 3

In [128]:

至于为什么这在 IDLE 中不起作用，请参阅this answer：

但是，要看到print 输出，至少在 Windows 上，必须从这样的控制台启动 IDLE。

C:\Users\Terry>python -m idlelib
hello bob

（在 2.x 上使用 idlelib.idle。）原因是 IDLE 在单独的进程中运行用户代码。目前，IDLE 进程和用户代码进程之间的连接是通过套接字进行的。多处理完成的分叉不会复制或继承套接字连接。通过图标或资源管理器（在 Windows 中）启动 IDLE 时，打印输出无处可去。从带有python（而不是pythonw）的控制台启动时，输出将进入控制台，如上所述。

Answer 2

您可能需要刷新输出。你可以使用sys.stdout.flush():

import multiprocessing
import sys

def worker(num):
    """thread worker function"""
    print('Worker:', num)
    sys.stdout.flush()
    return

if __name__ == '__main__':
    jobs = []
    for i in range(4):
        p = multiprocessing.Process(target=worker, args=(i,))
        jobs.append(p)
        p.start()