我有创建ThreadPool的主线程。在调用函数之前,使初始化池中的每个线程。所有线程将被初始化时如何等待?等待初始化池中的所有线程
例子:
from multiprocessing.pool import ThreadPool
def main():
# in main thread
pool = ThreadPool(processes=5, initializer=init_pool)
# >>> here it is I want to wait for initialized
pool.map_async(do_smth).get()
def init_pool():
# initialized new thread in pool
pass
def do_smth():
# do somethings
pass
有必要不引起map_async如果发生
我可以使用值从多处理用于此目的,但它是不漂亮的解决方案 – deniska369