import threading as th
from queue import Queue
lenAllData = 1000000
class ClassForQueue:
queueData = Queue()
def threadAddQueue():
# Симулируем заполнение очереди
for i in range(lenAllData):
ClassForQueue.queueData.put(i)
def threadProcQueue():
# симулируем разбор очереди
while True:
data_from_queue = ClassForQueue.queueData.get()
print(f'Length {ClassForQueue.queueData.qsize()}, last value {data_from_queue}')
# Запускаем и получаем рандом в выводе
if __name__ == '__main__':
th1 = th.Thread(target=threadAddQueue)
th1.start()
th2 = th.Thread(target=threadProcQueue)
th2.start()