因为multiprocessing.Queue依赖pickle序列化，而自定义类若定义在if name == '__main__':块内、为嵌套类或含不可序列化对象（如Lock），则无法被主模块顶层导入，导致AttributeError。
为什么 multiprocessing.Queue 不能直接用 pickle.dumps 传自定义类？
因为 multiprocessing.Queue 底层依赖 pickle 序列化数据，而它要求对象必须能被主模块顶层导入——也就是说，自定义类不能定义在 if __name__ == '__main__': 块里，也不能是嵌套类或 lambda。否则你会看到类似 AttributeError: Can't pickle local object 'foo.<locals>.MyClass'</locals> 的错误。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 把类定义放在模块最外层（.py 文件顶部），且确保该模块可被子进程 import（即不能是临时脚本或 Jupyter cell）
- 避免使用闭包、装饰器包裹的类、
dataclass带默认可变参数（如list）等易出序列化问题的结构 - 调试时先用
dict或tuple测试通路，再逐步替换成自定义类
put() 和 get() 阻塞行为怎么控制超时和异常？
put() 和 get() 默认会无限等待，但生产环境必须设防。不加超时可能让整个进程卡死，尤其当消费者崩溃而生产者还在发数据时。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 始终为
put()加timeout=参数，比如q.put(item, timeout=2)，超时抛queue.Full -
get()同理，用q.get(timeout=5)，超时抛queue.Empty - 捕获异常后要明确处理：重试？丢弃？记录日志？不要裸写
except: - 注意：
timeout是浮点数，单位秒；设为None表示无限等待（仅调试可用）
子进程退出后 Queue 中残留数据会丢失吗？
会。如果子进程异常终止（如未正常调用 join() 或被 os.kill() 强杀），其写入 Queue 的数据可能滞留在底层管道缓冲区中，主进程调用 get() 时无法读取，也不会报错，而是永远阻塞或超时——这常被误判为“通信失败”，实际是资源没清理干净。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 所有子进程必须通过
p.join()正常退出，或使用concurrent.futures.ProcessPoolExecutor这类带自动回收的封装 - 主进程结束前，显式调用
q.close()+q.join_thread()，确保后台线程把缓冲数据刷完 - 不要依赖
atexit或__del__清理队列，它们在子进程中不可靠
为什么有时 get() 返回 None 而不是预期数据？
常见原因是生产者调用了 q.put(None) 作为“结束信号”，但消费者没做类型检查，直接解包或使用。更隐蔽的情况是：生产者进程崩溃前意外写入了 None（比如函数返回值未显式指定，默认返回 None），而 Queue 不校验内容类型。
实操建议：
立即学习“Python免费学习笔记（深入）”；
- 避免用
None当哨兵值；改用枚举、字符串（如'STOP'）或自定义 sentinel 对象（确保可序列化） - 消费者端对每次
get()结果做is not None检查，或用try/except包裹关键解包逻辑 - 调试时可在
put()前加assert item is not None，快速暴露源头问题
put 和 get，而是当多个子进程并发写、消费者动态启停、网络 IO 混合进来时，队列的边界状态是否可控——这时候 timeout、close()、sentinel 设计，一个都不能少。 
