使用一个例子探析：生产者消费者在多线程之间的通信的使用

import random
def fun1():
    print("启动")
def fun2():
    x = random.random()
    a = x + 1
    b = x + 2
    c = x + 3
    return a, b, c
def fun3(a, b, c):
    y = a + b + c
    print(y)
复制代码

from queue import Queue
queue = Queue()  # 实例化队列
复制代码

from threading import Thread
import time
from queue import Queue
import Fun
class Producer(Thread):
    def __init__(self,queue):
        super(Producer, self).__init__()
        self.queue = queue
    def run(self):
        while True:
            x1, x2, x3 = Fun.fun2()
            self.queue.put(x1)
            self.queue.put(x2)
            self.queue.put(x3)
            time.sleep(1)
class Consumer(Thread):
    def __init__(self,queue):
        super(Consumer, self).__init__()
        self.queue = queue
    def run(self):
        while True:
            try:
                Fun.fun3(self.queue.get_nowait(), self.queue.get_nowait(), self.queue.get_nowait())
                print("队列长度", self.queue.qsize())
            except Exception:
                print('消费者出错')
            # time.sleep(random.randrange(2))
            time.sleep(1)
if __name__ == '__main__':
    print("---主线程开始---")
    Fun.fun1()
    queue = Queue()  # 实例化队列
    producer = Producer(queue)  # 实例化线程 Producer，并传入队列作为参数
    consumer = Consumer(queue)  # 实例化线程 Consumer，并传入队列作为参数
    producer.start()  # 启动线程 Producer
    consumer.start()  # 启动线程 Consumer
    producer.join()  # 等待线程 Producer 结束
    consumer.join()  # 等待线程 Consumer 结束
    print("---主线程结束---")