python高级线程编程-线程安全的数据结构（五）

queue.Queue

Queue是Python中的线程安全的队列，它可以让多个线程同时访问共享的队列，而不必担心数据一致性和完整性问题。Queue有两个基本操作：put()和get()。put()用于往队列中添加元素，get()用于从队列中取出元素。当队列为空时，get()会进入阻塞状态，直到队列中有元素可取。当队列已满时，put()也会进入阻塞状态，直到队列中有空间可用。

下面的示例展示了如何使用Queue来实现生产者-消费者模型：

import threading
import queue
import time

class Producer(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        while True:
            item = time.time()
            self.queue.put(item)
            print("Produced item: {
}
".format(item))
            time.sleep(1)

class Consumer(threading.Thread):
    def __init__(self, queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        while True:
            item = self.queue.get()
            print("Consumed item: {
}
    ".format(item))
            time.sleep(1)

if __name__ == '__main__':
    queue = queue.Queue(maxsize=10)

    producer = Producer(queue)
    consumer = Consumer(queue)

    producer.start()
    consumer.start()

    producer.join()
    consumer.join()

在上面的示例中，我们使用了一个Queue来作为生产者和消费者之间的共享数据结构，生产者不断往队列中添加元素，当队列已满时，它会等待消费者消费一些元素后再继续添加。消费者不断从队列中取出元素，当队列为空时，它会等待生产者添加元素后再继续取出。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！