Queue-Multi Threading Python

Question

У меня есть куча кода, и я прилагаю здесь кусок. В принципе у меня есть нить, - которая ориентирована на функции - которая имеет время цикла следующим образом:

while not stop_event.wait(1): # Continuous Reading Function 

    #print "hello2" 
    #print ("working on %s" % arg) 
    data1 = Read(soa1, bytes1, ser) 
    data2 = Read(soa2, bytes2, ser) 
    data3 = Read(soa3, bytes3, ser) 

    data = np.concatenate([data1, data2, data3]) 
    print data.size 
    queue_read.put(data) 
    time.sleep(1) 

Я чтение данных из MCU, через последовательный канал связи в этой теме и отправить его обратно к моему главному program - используя queue_read.put (данные). Это происходит каждые 1 секунду.

В моей основной программе я читаю выход из этого потока, как ---

self.data = queue_read.get() 

Через пять минут значения в MCU намеренно изменены. Во время изменения этот поток все еще работает, поскольку он находится в цикле while.

Итак, после пяти минут переменная «данные» должна иметь обновленные новые значения из MCU. Но, к моему удивлению, это не так. Он все еще имеет начальные значения. Здесь что-то не хватает? Использует ли очередь, правильный способ получить данные?

Answer 1

Следующий подход считывает и обрабатывает данные из непрерывно очереди, которая позволяет видеть и реагировать на изменения данных, как они происходят:

while True: 
    self.data = queue_read.get() 
    self.update_GUI() 

queue_read.get() блоков, если queue_read пуст. Вам нужно будет запустить этот код в своем потоке, если основной поток выполняет что-либо, кроме обновления графического интерфейса.