Python多线程通信问题实例-向日葵屋

Python多线程通信问题实例

原创 Myth丶恋晨 2025-01-30 05:24 10阅读 0赞

在Python中，多线程的通信主要依赖于三个核心组件：全局变量（Global Variables）、锁（Locks）和队列（Queues）。

以下是一个简单的例子，展示如何使用这些工具进行多线程通信：

import threading
import queue
# 全局变量
counter = 0
# 定义一个生产者线程
def producer():
    global counter
    while True:
        # 生产一个计数器值
        counter += 1
        # 将计数器值放入队列中
        q.put(counter)
# 定义一个消费者线程
def consumer(q):
    while True:
        # 从队列中获取一个计数器值
        counter = q.get()
        # 处理这个计数器值（例如打印）
        print(f"Received: {counter}")
# 创建生产者和消费者线程
producer_thread = threading.Thread(target=producer)
consumer_thread = threading.Thread(target=consumer, args=(queue.Queue(),)))
# 启动线程
producer_thread.start()
consumer_thread.start()
# 等待所有线程完成
producer_thread.join()
consumer_thread.join()