放，B不停的取，A和B的放取速度不一致，就可以用队列来做 import multiprocessing import queue import time import random def producer_a(test_queue): product_id = 1 while True: print('A 查看当前队列长度：', test_queue.qsize()) test_queue = multiprocessing.JoinableQueue(maxsize=5) # 先进先出队列 p = multiprocessing.Process(target=producer_a, args= (test_queue,)) c = multiprocessing.Process(target=consumer_b, args= (test_queue,)) ，A不停的 放，B不停的取，A和B的放取速度不一致，就可以用队列来做 import threading import queue import time import random def producer_a(): product_id = 1 while True: print('A 查看当前队列长度：', test_queue.qsize())