
Python线程池回调函数:执行线程探秘
Python线程池中的回调函数执行线程,取决于回调函数的添加时机。
主线程情景:
如果在提交任务后立即添加回调函数,且任务执行速度极快,在回调函数执行前任务已完成,那么回调函数将在主线程中执行。这是因为线程池尚未为任务分配工作线程。
立即学习“Python免费学习笔记(深入)”;
工作线程情景:
然而,如果在任务执行期间或完成后添加回调函数,则回调函数将在执行该任务的工作线程中执行。这是因为任务已分配给工作线程,工作线程会在任务完成后执行回调函数。
代码示例:
以下两个示例演示了回调函数在不同线程中的行为:
import concurrent.futuresimport threadingimport timedef my_task(): return Nonedef 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)
运行结果:
第一个循环的输出将显示主线程名称,第二个循环的输出将显示多个工作线程名称。
以上就是Python线程池回调函数:究竟在哪个线程执行?的详细内容,更多请关注创想鸟其它相关文章!
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1356634.html
微信扫一扫
支付宝扫一扫