同一进程内多线程间数据传递异常：multiprocessing.Queue无法传值

嘿，兄弟，你这问题我太熟啦——你用错队列类型了！

multiprocessing.Queue是专门给跨进程通信设计的，它底层靠管道和进程级锁来保证数据安全，但同一进程里的线程用它完全是“杀鸡用牛刀”，而且反而会因为它的进程级封装逻辑，导致线程间的数据传递出问题，比如你遇到的读不到数据的情况。

线程间通信应该用标准库的queue.Queue（注意是小写q开头的那个！），这个是专门为线程安全设计的队列，内置了线程级的锁，同一进程内的线程可以完美配合它进行数据传递。

给你改好的代码示例 #

假设你的两个文件原来的结构大概是这样，我给你改成正确的版本：

修改后的mainClass.py #

import queue  # 替换成标准库的queue模块
from NewItemInterestHelper import NewItemInterestHelper

class MainClass:
    def __init__(self):
        # 用线程安全的queue.Queue替代multiprocessing.Queue
        self.data_queue = queue.Queue()
        self.helper_thread = NewItemInterestHelper(self.data_queue)
        self.helper_thread.start()
        
        # 主线程往队列写入数据
        self.data_queue.put("这是要传递的测试字符串")
        print("主线程已将数据写入队列")

if __name__ == "__main__":
    main_instance = MainClass()

修改后的NewItemInterestHelper.py #

import threading
import queue  # 同样导入标准库的queue

class NewItemInterestHelper(threading.Thread):
    def __init__(self, target_queue):
        super().__init__()
        self.queue = target_queue
        
    def run(self):
        print("子线程启动，等待读取队列数据...")
        # 这里会阻塞直到队列有数据
        received_data = self.queue.get()
        print(f"子线程成功读取到数据：{received_data}")

为啥这样改就好使？ #

标准库的queue.Queue天生支持同一进程内的线程安全操作：

• 它内部自带了threading.Lock和threading.Condition，能保证多个线程同时读写队列时不会出现数据混乱。
• put()和get()方法都是阻塞式的（可以通过参数改成非阻塞），只要队列里有数据，子线程的get()就能立刻读到，不会出现莫名其妙的阻塞或读空情况。

额外注意点 #

• 如果你以后真的需要跨进程传递数据，那再用multiprocessing.Queue，但线程场景下绝对别碰它。
• 调试的时候可以用queue.qsize()查看队列里的元素数量，或者queue.empty()判断是否为空，方便排查问题。
• 线程间通信除了队列，还可以用threading.Event（通知线程事件）、threading.Lock（保护共享变量）等工具，根据你的具体需求选就行。

内容的提问来源于stack exchange，提问作者Wesley