join() 方法不返回结果且不支持泛型类型提取，仅同步等待线程或进程结束；要安全等待并获取泛型结果，应使用 threadpoolexecutor 的 future.result()、multiprocessing.queue.get() 或封装的 get_result() 等配套机制。
join() 方法本身不返回结果，也不支持泛型类型提取。它只是一个同步原语，作用是让当前线程暂停执行，直到目标线程（或进程）自然结束。你无法通过 thread.join() 或 process.join() 直接“拿到”子任务的返回值——这是 Python 线程/进程模型的基本限制。
要安全等待 + 获取结果，需配合其他机制。下面分场景说明关键做法：
✅ 线程中等待并获取结果：用 concurrent.futures.ThreadPoolExecutor
这是最推荐、最简洁、天然支持泛型结果的方式：
from concurrent.futures import ThreadPoolExecutor
import time
def fetch_data(x: int) -> str:
time.sleep(1)
return f"result_{x}"
with ThreadPoolExecutor() as executor:
# 提交任务，立即返回 Future 对象（带类型提示）
future = executor.submit(fetch_data, 42)
# 阻塞等待完成，并直接获取返回值（类型为 str）
result: str = future.result() # ← 这里隐式调用了类似 join 的等待逻辑
print(result) # "result_42"
-
future.result()会阻塞，直到任务完成； - 返回值类型由函数签名决定，IDE 和类型检查器（如 mypy）能准确推导；
- 异常也会在
result()中重新抛出，便于捕获处理。
✅ 多个线程批量等待并收集泛型结果
def compute(x: float) -> float:
return x ** 2 + 1
with ThreadPoolExecutor(max_workers=3) as executor:
futures = [executor.submit(compute, x) for x in [1.0, 2.0, 3.0]]
# 一次性等待全部完成，并提取结果（保持顺序）
results: list[float] = [f.result() for f in futures]
print(results) # [2.0, 5.0, 10.0]
✅ 自定义线程类 + 安全结果存储（不推荐，但可理解原理）
如果你坚持手动用 threading.Thread，必须自行管理结果容器（注意线程安全）：
import threading
from typing import Optional, Any
class ResultThread(threading.Thread):
def __init__(self, target, *args, **kwargs):
super().__init__(target=target, *args, **kwargs)
self._result: Optional[Any] = None
self._exc: Optional[Exception] = None
def run(self):
try:
# 假设 target 是一个返回值的函数
self._result = self._target(*self._args, **self._kwargs)
except Exception as e:
self._exc = e
def get_result(self) -> Any:
if self._exc is not None:
raise self._exc
return self._result
# 使用示例
def task() -> int:
return 123
t = ResultThread(target=task)
t.start()
t.join() # ← 精准阻塞主线程
val: int = t.get_result() # ← 安全提取结果（类型可注解）
⚠️ 注意：这种方式需手动处理异常、不支持超时中断、无法组合多个任务，已属低阶写法。
✅ 进程间结果传递：用 multiprocessing.Queue 或 Manager
Process.join() 同样不返回值，需搭配通信机制：
from multiprocessing import Process, Queue
def worker(q: Queue, x: int):
q.put(x * 2)
q = Queue()
p = Process(target=worker, args=(q, 21))
p.start()
p.join() # 等待子进程结束
result: int = q.get() # 从队列取结果
Queue是进程安全的，适合跨进程传递任意可序列化对象；类型需靠文档或注解约定，运行时不校验。
join() 只负责“等”，不负责“拿”。真正实现「精准阻塞 + 泛型结果提取」的，是 Future.result()、Queue.get() 或封装后的 get_result() 这类配套方法。选对高层抽象（如 ThreadPoolExecutor），比手写 join() + 全局变量安全得多、清晰得多。
