线程：线程在完成作业之前退出

Question

我试图理解Python线程的“守护进程”标志。这我知道

线程可以标记为“守护线程”。此标志的意义在于，当只剩下守护进程线程时，整个Python程序将退出。初始值从创建线程继承。

但在我的例子中，python程序在守护进程线程离开并且线程没有完成其工作之前退出。

def ThreadDecorator(f):
    def wrap(*args,**kargs):
        t=Thread(target=f,args=args,kwargs=kargs)
        t.daemon=True
        t.start()
return wrap

@ThreadDecorator
def runSomething(*args,**kwargs):
    i = 0
    attente = 0
    fileName=kwargs['file']
    f=open(fileName,'wt')
    while i < 50000:
        f.write(str(i)+"\n")
        # attente += 0.2
        # attente += random.randint(1, 60) / 100
        # time.sleep(attente)
        i += 1
    f.close()
    return "Finished"

主程序

runSomething("5",file='test1.txt')
runSomething("6",file='test2.txt')

第一个线程只写5000个第一个整数，而第二个线程不写任何数字

Answer 1

我觉得主块应该包含一个池。一旦所有线程都完成了，就可以调用pool.close（）来确保所有线程都完成了执行。

from multiprocessing import Pool
from datetime import datetime

pool = Pool(processes = 2)
num_workers = 2
curr_worker = 1
val = 5
if (curr_worker < num_workers ):
    file_name = 'test'+str(curr_worker)+'.txt'
    pool.apply_async(run_Something,args=(val,file_name,)))
    curr_worker += 1
    val += 1
else:
    pool.close()
    pool.join()
    curr_worker = 1
    val = 5
print ("Workers returned result", datetime.now().strftime('%Y-%m-%d %H:%M:%S'))

主进程在启动守护进程线程后退出。由于守护进程线程在非守护进程主线程终止时停止，因此我们只看到test1。txt有5000条记录。

主要的任务是启动下面的帖子，它将退出：

runSomething("5",file='test1.txt')
runSomething("6",file='test2.txt')