使用 time.sleep 时 Python 多处理不起作用

Question

我有一个函数可以接受不同的输入，我希望该函数并行运行。以下是我尝试过的，但由于 time.sleep 我认为它不起作用。

from multiprocessing import Process
from time import sleep
import time

def f(name):
    print('hello', name)
    time.sleep(10)

l1 = Queue()
a = Process(target=f('Tom'))
a.start()

l2 = Queue()
b = Process(target=f("Stock"))
b.start()

print (l1.get())
print (l2.get())

我希望函数并行运行。目前该函数在进入第二次执行之前等待 10 秒。

Answer 1

查看@juanpa.arrivillaga 发表的评论。只需将函数的 name 指定为 Process 构造函数的 target 参数即可；不要调用该函数。 target 的参数单独指定为 args 参数，可以是 tuple 或 list。

此外，由于f 没有返回有用的值，因此没有理由为结果使用Queue 实例。在任何情况下，您都没有将Queue 实例传递给f，也没有将put 传递给队列，所以我不明白为什么您会尝试针对这些get 发出调用Queue实例；这些电话将永远挂起。您做需要传递给f的参数是名称，如下：

from multiprocessing import Process
#from time import sleep
import time

def f(name):
    print('hello', name)
    time.sleep(10)

start_time = time.time()

a = Process(target=f, args=('Tom',))
a.start()

b = Process(target=f, args=("Stock",))
b.start()

# Wait for processes to complete
a.join()
b.join()

elapsed_time = time.time() - start_time
print(elapsed_time)

打印：

hello Tom
hello Stock
10.212252855300903

如果您在 Windows 等平台上运行它，那么您需要将创建进程的代码放在一个特殊的块中，如下所示；

from multiprocessing import Process
#from time import sleep
import time

def f(name):
    print('hello', name)
    time.sleep(10)

# Required on platforms that create processes with the "spawn" method:
if __name__ == '__main__':
    start_time = time.time()

    a = Process(target=f, args=('Tom',))
    a.start()

    b = Process(target=f, args=("Stock",))
    b.start()

    # Wait for processes to complete
    a.join()
    b.join()

    elapsed_time = time.time() - start_time
    print(elapsed_time)

Answer 2

使用Pool 和starmap：

import multiprocessing
import time

def f(name, place):
    print('hello', name, place)
    time.sleep(5)

if __name__ == '__main__':
    data = [('Louis', 'val1'), ('Paul', 'val2'), ('Alexandre', 'val3'),
            ('John', 'val4'), ('Tom', 'val5'), ('Bob', 'val6')]
    with multiprocessing.Pool(2) as pool:
        pool.starmap(f, data)

仔细阅读multiprocessing guidlines

安全导入主模块

确保新的 Python 解释器可以安全地导入主模块，而不会导致意外的副作用（例如启动新进程）。