Python如何使用threading实现不同线程间异步发送字符串

你要的消息邮箱机制Python标准库已经有原生实现，直接用queue.Queue即可，不需要手动维护threading.Event、共享内存和相关同步逻辑，完全适配你的IO绑定多线程场景。

核心优势 #

• 无空转开销：接收线程调用get()方法时默认阻塞等待消息，不需要轮询标记，不会浪费CPU资源
• 天然线程安全：队列内部已经实现了锁逻辑，多线程同时读写不会出现竞态条件
• 不用手动管理共享内存：消息直接入队出队，不需要自己维护共享变量的读写逻辑
• 适配任意发送时机：消息会暂存在队列中，接收线程空闲后自动读取，不会出现消息丢失

最简实现示例 #

import threading
import queue

# 初始化消息邮箱（线程安全队列）
msg_mailbox = queue.Queue()

def receiver_task():
    while True:
        # 阻塞等待接收消息，无消息时自动挂起不占CPU
        received_str = msg_mailbox.get()
        # 可选：约定退出标记，收到后结束线程
        if received_str == "__exit__":
            msg_mailbox.task_done()
            break
        # 这里写你处理接收字符串的业务逻辑
        print(f"处理接收到的字符串: {received_str}")
        # 标记当前消息处理完成，可选，需要等待队列全处理完时使用
        msg_mailbox.task_done()

# 启动接收线程
receiver_thread = threading.Thread(target=receiver_task, daemon=True)
receiver_thread.start()

# 任意线程、任意时机都可以直接发消息，不需要处理同步逻辑
msg_mailbox.put("异步发送的第一条测试字符串")
# 可以在任意触发逻辑里调用put发送消息
# 例如IO回调、用户操作触发等场景
msg_mailbox.put("第二条随机时机发送的字符串")

# 需要停止接收线程时发送退出标记
msg_mailbox.put("__exit__")
receiver_thread.join()

可选配置 #

如果需要限制消息堆积的最大长度，初始化队列时传入maxsize参数即可：msg_mailbox = queue.Queue(maxsize=100)，队列满时put()操作会默认阻塞，也可以通过参数配置为满时抛出异常、直接丢弃消息等行为，适配不同业务需求。

你提到的「隐式变量语义」对应的threading.local是线程局部存储方案，仅能实现同一个线程内的全局变量共享，无法用于跨线程传递消息，不适合当前场景。

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