
Python线程池回调函数:执行线程探秘
Python线程池中的回调函数执行线程,取决于回调函数的添加时机。
主线程情景:
如果在提交任务后立即添加回调函数,且任务执行速度极快,在回调函数执行前任务已完成,那么回调函数将在主线程中执行。这是因为线程池尚未为任务分配工作线程。
立即进入“豆包AI人工智官网入口”;
立即学习“豆包AI人工智能在线问答入口”;
工作线程情景:
然而,如果在任务执行期间或完成后添加回调函数,则回调函数将在执行该任务的工作线程中执行。这是因为任务已分配给工作线程,工作线程会在任务完成后执行回调函数。
代码示例:
以下两个示例演示了回调函数在不同线程中的行为:
<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>运行结果:
第一个循环的输出将显示主线程名称,第二个循环的输出将显示多个工作线程名称。
以上就是Python线程池回调函数:究竟在哪个线程执行?的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号