Python MultiProcessing.Pool : How to use with no iterable?

Question

多线程进程

    p = ThreadPool(processes=10)  # creates a pool of 10 workers
    p.map(function_to_call, iterable)  # calls FUNCTION_TO_CALL with the first item from iterable as parameter
    p.close()  # closes the multi-threaded processes one all threads done

我一直在尝试使用这个模型，但是如果我想线程化一个没有参数的函数怎么办。像 run() 。我会为“可迭代”空间放什么，我一直在四处寻找，但找不到解决方案。

Answer 1

Pool.apply 功能就是你要找的。使用 Pool.apply_async如果你想要一个非阻塞调用。

p = ThreadPool(processes=10)
p.apply(function_to_call)
p.close()