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

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()