作者回复: 在文件内，模块（函数）外声明的都是全局变量，
这里使用的global是声明在类中使用的queue是全局变量，避免class内部误声明同名的queue变量发生冲突。

作者回复: 问题出在产生了一个数据，但是并没有将他放在队列里面（queue.put(num)）啊，当第二个线程执行到num = queue.get()时会“暂停”，直到有数据写入队列，所以你只看到打印生产数据，没看到消费数据

作者回复: 一定要判断的，我这里没有演示是因为queue包对已满队列有自己的处理机制，而不是抛出异常。可以自己尝试一下，如果只往队列写，不读取会发生什么结果？通过官方文档查看如何判断队列是否已满？

作者回复: 是的，这是引用了queue库时引入的，类似异常处理。

作者回复: task_done()作用：如果 join() 当前正在阻塞，在所有条目都被处理后，将解除阻塞

参考等待排队的任务被完成的示例：

import queue
import threading

def worker():
    while True:
        item = q.get()
        if item is None:
            break
        print(item, 'run')
        #注释q.task_done()这行查看程序运行结果进行对比
        q.task_done()


q = queue.Queue()
threads = []
num_worker_threads = 2

for i in range(num_worker_threads):
    t = threading.Thread(target=worker)
    t.start()
    threads.append(t)

for item in range(10):
    q.put(item)

# block until all tasks are done
q.join()

# stop workers
for i in range(num_worker_threads):
    q.put(None)
for t in threads:
    t.join()

作者回复: 是否您的文件名就是 queue.py 呢？

作者回复: p1是ProducerThread()类的实例化，ProducerThread()继承了threading类，当我调用p1.start()方法时，class ProducerThread(Thread)类会自动调用run()方法。

首先强调一下这段代码的目的性：这里我写ProducerThread(name='p1')目的是想使用 p1 c1 c2的名字替代 thread-1 、 thread-2、 thread-3 ...这样的默认名称，为的是输出时方便大家看效果。这个功能要在实例化的时候使用，所以不能用__init__ 初始化name

python传参是可以传“关键字参数”的，这里使用的name='p1'并不是第一个参数是线程名，而是我在run()方法定义了name变量，实例化的时候重传name进行覆盖。