多线程进程
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((。我会为"迭代"空间放置什么,我一直在环顾四周,找不到解决方案。
Pool.apply
函数是您想要的。如果需要非阻止呼叫,请使用Pool.apply_async
。
p = ThreadPool(processes=10)
p.apply(function_to_call)
p.close()