python 进/线程基础

可以参考另外一位同学写的博客
https://blog.csdn.net/u013210620/article/details/78687028

python 线程池添加的回调函数运行是在哪个线程中？

在Python的concurrent,futures模块中 当你向ThreadPoolExecutor提交任务（即调用submit函数）时，任务会在池中的一个线程中执行。一旦任务完成，任何通过add_ done_callback方法添加的回调函数都会被调用。
这些回调函数是在执行任务的那个线程（即完成工作的工作者线程）中执行的 ，而不是在主线程中。这意味着回调函数的执行是在池中线程的上下文中，以异步方式进行的。因为它们在线程池的工作线程内执行，你仍然需要注意线程安全的问题，尤其是当回调函数尝试访问共享资源或变量时。一定要确保你在回调函数中执行的操作是线程安全的，避免引入党态条件。如果必要，你可以使用锁等同步 原语来保护对共享资源的访问。

多个任务的回调函数是在同一个线程中，还是分别在各自的线程中完成？

当你使用Python的concurrent.futures.ThreadPooLExecutor提交多个任务时，每个任务将被分配到线程池中的一个工作线程中去执行。这些任务可以并行执行 （具体取决于系统的线程调度和可用核心数）。对于这些任务的回调函数，它们是在这些任务完成执行后被调用的。
关于回调函数是在同一个线程中执行，还是在不同的线程中执行，关键点在于：

1. 不同任务的回调函数可能会在不同的线程中执行。 每个任务的回调函数是在该任务完成后由执行该任务的线程触发的。（如果两个任务恰好被分配给了线程池中的不同线程，它们的回调函数也会在这些线程中分别执行。
2. 相同或相关任务的回调函数可能会在同一个线程中执行 ，如果这些任务恰好被分配给相同的线程。
3. 线程池的工作方式是重用线程。 当一个线程完成任务并运行了对应的回调函数之后，这个线程可能会被分配给另一个任务。这意味着，即使多个任务的回调函数可能在逻辑上是相互独立的，它们也可能在物理上由同一个线程（在不同时间点）执行。

总的来说，回调函数是与其对应的任务相关联的，并在任务执行的线程中被调用。不同任务的回调函数可以在不同的线程中执行，这完全取决于任务是如何被线程池中的线程执行的。因此，在编写回调函数时，你应该假设它们可能在多线程环境下运行，并确保任何共享资源的访问都是线程安全的。

talk is cheap，show your code

import concurrent.futures
import threading
import timedef task(n):thread_name = threading.current_thread().nameif thread_name == "MainThread":thread_type = "主线程"else:thread_type = "子线程"time.sleep(1)print(f"执行函数的输入是：{n}, 在 {thread_type} ({thread_name}) 中执行。")return ndef callback(future):thread_name = threading.current_thread().nameif thread_name == "MainThread":thread_type = "主线程"else:thread_type = "子线程"result = future.result()print(f"回调函数的结果：{result}, 在 {thread_type} ({thread_name}) 中执行。")# 获取主线程的名称
main_thread_name = threading.current_thread().name# 使用线程池并为每个任务添加回调函数
with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor:futures = []for i in range(5):future = executor.submit(task, i)future.add_done_callback(callback)futures.append(future)# 等待所有的任务完成concurrent.futures.wait(futures)# 程序运行结束
print(f"主程序在 {main_thread_name} 中运行完毕。")