Python多线程间数据共享的有效方法：使用队列

import threading
import time
from queue import Queue


def publisher(consumers):
    """
    生产者线程函数，将数据发送到每个消费者的队列中。
    """
    for x in range(10):
        value = 2 ** x
        for consumer in consumers:
            consumer.put(value)
        time.sleep(0.1)
    # 发送结束信号
    for consumer in consumers:
        consumer.put(None)  # sentinel value to indicate end of stream


def consumer(name, queue):
    """
    消费者线程函数，从自己的队列中获取数据并处理。
    """
    while True:
        value = queue.get()
        if value is None:
            print(f"{name} will quit now")
            break
        print(f"{name}: Got {value}")


def main():
    """
    主函数，创建生产者和消费者线程，并启动它们。
    """
    consumer_threads = []
    consumer_queues = []
    # 创建多个消费者线程和对应的队列
    for x in range(3):
        queue = Queue()
        consumer_queues.append(queue)
        thread = threading.Thread(target=consumer, args=(f"Consumer {x}", queue))
        thread.start()
        consumer_threads.append(thread)
    # 创建生产者线程
    publisher_thread = threading.Thread(target=publisher, args=(consumer_queues,))
    publisher_thread.start()
    # 等待生产者线程结束
    publisher_thread.join()
    # 等待所有消费者线程结束
    for thread in consumer_threads:
        thread.join()


if __name__ == "__main__":
    main()