
Python线程池回调函数:执行线程探秘
Python线程池中的回调函数执行线程,取决于回调函数的添加时机。
主线程情景:
如果在提交任务后立即添加回调函数,且任务执行速度极快,在回调函数执行前任务已完成,那么回调函数将在主线程中执行。这是因为线程池尚未为任务分配工作线程。
立即学习“Python免费学习笔记(深入)”;
工作线程情景:
函数是一组语句一起执行任务。在MATLAB中,函数定义在单独的文件。文件函数的文件名应该是相同的。 函数操作在自己的工作空间,它也被称为本地工作区,独立的工作区,在 MATLAB 命令提示符访问,这就是所谓的基础工作区的变量。函数可以接受多个输入参数和可能返回多个输出参数 。 MATLAB是MathWorks公司开发的一种编程语言。它最初是一个矩阵的编程语言,使线性代数编程很简单。它可以运行在交互式会话和作为批处理作业。有需要的朋友可以下载看看
然而,如果在任务执行期间或完成后添加回调函数,则回调函数将在执行该任务的工作线程中执行。这是因为任务已分配给工作线程,工作线程会在任务完成后执行回调函数。
代码示例:
以下两个示例演示了回调函数在不同线程中的行为:
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)
运行结果:
第一个循环的输出将显示主线程名称,第二个循环的输出将显示多个工作线程名称。









