
Python线程池回调函数:执行线程探秘
Python线程池中的回调函数执行线程,取决于回调函数的添加时机。
主线程情景:
如果在提交任务后立即添加回调函数,且任务执行速度极快,在回调函数执行前任务已完成,那么回调函数将在主线程中执行。这是因为线程池尚未为任务分配工作线程。
立即学习“Python免费学习笔记(深入)”;
工作线程情景:
然而,如果在任务执行期间或完成后添加回调函数,则回调函数将在执行该任务的工作线程中执行。这是因为任务已分配给工作线程,工作线程会在任务完成后执行回调函数。
代码示例:
以下两个示例演示了回调函数在不同线程中的行为:
<code class="python">import concurrent.futures
import threading
import time
def my_task():
return None
def my_callback(future):
print(threading.current_thread().name)
with concurrent.futures.ThreadPoolExecutor(max_workers=10) as executor:
# 主线程执行回调
for _ in range(10):
future = executor.submit(my_task)
future.add_done_callback(my_callback)
# 工作线程执行回调
for _ in range(10):
future = executor.submit(my_task)
time.sleep(1) # 保证任务在添加回调前完成
future.add_done_callback(my_callback)</code>
运行结果:
第一个循环的输出将显示主线程名称,第二个循环的输出将显示多个工作线程名称。









