小编N3T*_*C4t的帖子

我想阻止来自单个工作者的所有线程.

我有一个包含10名工人的线程池:

def myfunction(i):
    print(i) 
    if (i == 20):
        sys.exit()

p = multiprocessing.Pool(10, init_worker) 

for i in range(100):
    p.apply_async(myfunction, (i,))

我的程序没有停止,其他进程继续工作,直到所有100次迭代完成.我想完全从调用的线程内部停止池sys.exit().它当前编写的方式只会阻止调用的工作者sys.exit().