我怎样可以为
multiprocessing.Pool
中的每个进程设置优先级?我知道可以通过os.nice()
增加优先级,但是在创建池后如何在子进程中调用它?如果我在映射函数中调用它,那么每次函数执行时都会被调用,而不是在进程fork时只调用一次。import multiprocessing as mp
NICENESS = 19
DATA = range(100000)
def foo(bar):
return bar * 2
pool = mp.Pool(100)
# Somehow set niceness of each process to NICENESS
pool.map(foo, DATA)