Python中的并发队列和线程安全队列

import queue
import threading

# 定义一个线程安全队列
q = queue.Queue()

# 定义一个生产者线程，用于向队列中添加数据
class ProducerThread(threading.Thread):
    def run(self):
        global q
        for i in range(10):
            q.put("pidancode.com")
            print("生产者线程向队列中添加元素：pidancode.com")

# 定义一个消费者线程，用于从队列中获取数据
class ConsumerThread(threading.Thread):
    def run(self):
        global q
        for i in range(10):
            item = q.get()
            print("消费者线程从队列中获取元素：%s " % item)

# 实例化生产者线程和消费者线程
producer = ProducerThread()
consumer = ConsumerThread()

# 启动线程
producer.start()
consumer.start()

# 等待线程结束
producer.join()
consumer.join()