终止线程和子线程

Question

我将多个线程与子线程一起使用。现在我想停止父线程或等到父线程完成工作而不检查并停止所有子线程。 我的想法是用一个进程包装父线程，然后终止进程，这似乎终止了相应的父线程及其所有子线程。

def worker(conn):

    #this is the class including the parent thread
    xi = Test_Risk_Calc('99082')
    #start working
    xi.test()    
    #finished

    print ('EVERYTHING IS DONE, BUT CHILD THREADS ARE STILL ALIVE')
    conn.send('EXIT SEND')
    return

def main():
    parent_conn, child_conn = Pipe()
    p = multiprocessing.Process(target=worker, args=(child_conn,))
    p.start()
    #wait for finished parent-thread
    print(parent_conn.recv())
    p.terminate()
    p.join()
    print('JOINED, PROCESS AND ALL ITS THREADS ARE TERMINATED')
    return

我不确定这是否是解决问题的正确方法

Answer 1

我认为你已经做到了。但是，您可以避免总是有点“硬”的“终止”。

对此的简单解决方案是使用参数“daemon = True”启动子线程。如果父线程终止，这实际上会自动终止子线程。

就像我之前说的，这可能看起来更干净一些，但我认为最终还是一样的。

编辑：

也许考虑使用 asyncio (async/await) 进行并发编程。您可以使用

创建任务

task = asyncio.create_task(my_task())

稍后取消这些任务

task.cancel()

这里的好处是，这个“取消”会向任务中抛出异常。所以在任务中你可以做这样的事情：

async def my_task():
  try:
    ... stuff ...
  except asyncio.CancelledError:
    ... you can handle the cancellation, or ignore it

在python中，任务不是很有用。对于并发执行，您可以更好地使用 asyncio，如果您有 cpu-bound 任务，您可以使用多处理（可能以进程池的形式）。