Как я могу получить данные без блокировки? - PullRequest
Новая
       19

Как я могу получить данные без блокировки?

0 голосов
/ 18 апреля 2019

У меня есть последовательный порт внешнего устройства для получения данных. Я установил два таймера. Один из них должен быть для печати (0.5sn), а другой - для записи в текстовый файл (15sn). Таймеры не должны получать данные друг от друга по списку или массиву. Потому что иногда мне нужно закрыть кнопку построения.

Итак, я должен получать данные с одного и того же ресурса (поступающие непрерывные данные), верно? Но когда я пытаюсь это сделать, он блокируется.

А как получить данные без блокировки? В качестве примера приведенный ниже код работает без блокировки: 

# -*- coding: utf-8 -*- 
#!/usr/bin/python
import time
import numpy as np
import sys
import wx

def next_data():
    t0 = time.time()
    return t0

class MyFrame1 ( wx.Frame ):

    def __init__( self, parent ):
        wx.Frame.__init__ ( self, parent, id = wx.ID_ANY, title = wx.EmptyString, pos = wx.DefaultPosition, size = wx.Size( 223,183 ), style = wx.DEFAULT_FRAME_STYLE|wx.TAB_TRAVERSAL )

        self.SetSizeHints( wx.DefaultSize, wx.DefaultSize )

        bSizer1 = wx.BoxSizer( wx.VERTICAL )

        self.toggleBtn1 = wx.ToggleButton( self, wx.ID_ANY, u"Btn 1(enabled)", wx.DefaultPosition, wx.DefaultSize, 0 )
        bSizer1.Add( self.toggleBtn1, 1, wx.ALL|wx.EXPAND, 5 )

        self.toggleBtn2 = wx.ToggleButton( self, wx.ID_ANY, u"Btn 2(enabled)", wx.DefaultPosition, wx.DefaultSize, 0 )
        bSizer1.Add( self.toggleBtn2, 1, wx.ALL|wx.EXPAND, 5 )


        self.SetSizer( bSizer1 )
        self.Layout()
        self.timer1 = wx.Timer()
        self.timer1.SetOwner( self, 1 )
        self.timer1.Start( 1000 )

        self.timer2 = wx.Timer()
        self.timer2.SetOwner( self, 2 )
        self.timer2.Start( 1000 )


        self.Centre( wx.BOTH )

        # Connect Events
        self.toggleBtn1.Bind( wx.EVT_TOGGLEBUTTON, self.btn1_f )
        self.toggleBtn2.Bind( wx.EVT_TOGGLEBUTTON, self.btn2_f )
        self.Bind( wx.EVT_TIMER, self.timer1_f, id=1 )
        self.Bind( wx.EVT_TIMER, self.timer2_f, id=2 )

    def btn1_f( self, event ):
        event.Skip()

    def btn2_f( self, event ):
        event.Skip()

    def timer1_f( self, event ):
        t1 = next_data()
        print("t1     :    ",t1)

    def timer2_f( self, event ):
        t2  = next_data()
        print("t2*****:    ",t2)

app = wx.App()
f = MyFrame1(None)
f.Show(True)
app.MainLoop()

И печатает (как положено): 

t2*****:     1555568620.1363716
t1     :     1555568620.1363716
t2*****:     1555568621.1300163
t1     :     1555568621.1300163

Однако мой последовательный порт работает неправильно, как указано выше: 

# -*- coding: utf-8 -*- 
#!/usr/bin/python
import time
import numpy as np
import sys
import wx
import serial

ser = serial.Serial('COM9',9600)

def next_data():
    #===========================================================================
    # for line in ser:       
    #     return line
    #===========================================================================
    data_str = ser.read(ser.inWaiting())  
    return data_str

## also the commented above 2 lines gave same output.


class MyFrame1 ( wx.Frame ):

    def __init__( self, parent ):
        wx.Frame.__init__ ( self, parent, id = wx.ID_ANY, title = wx.EmptyString, pos = wx.DefaultPosition, size = wx.Size( 223,183 ), style = wx.DEFAULT_FRAME_STYLE|wx.TAB_TRAVERSAL )

        self.SetSizeHints( wx.DefaultSize, wx.DefaultSize )

        bSizer1 = wx.BoxSizer( wx.VERTICAL )

        self.toggleBtn1 = wx.ToggleButton( self, wx.ID_ANY, u"Btn 1(enabled)", wx.DefaultPosition, wx.DefaultSize, 0 )
        bSizer1.Add( self.toggleBtn1, 1, wx.ALL|wx.EXPAND, 5 )

        self.toggleBtn2 = wx.ToggleButton( self, wx.ID_ANY, u"Btn 2(enabled)", wx.DefaultPosition, wx.DefaultSize, 0 )
        bSizer1.Add( self.toggleBtn2, 1, wx.ALL|wx.EXPAND, 5 )


        self.SetSizer( bSizer1 )
        self.Layout()
        self.timer1 = wx.Timer()
        self.timer1.SetOwner( self, 1 )
        self.timer1.Start( 1000 )

        self.timer2 = wx.Timer()
        self.timer2.SetOwner( self, 2 )
        self.timer2.Start( 1000 )


        self.Centre( wx.BOTH )

        # Connect Events
        self.toggleBtn1.Bind( wx.EVT_TOGGLEBUTTON, self.btn1_f )
        self.toggleBtn2.Bind( wx.EVT_TOGGLEBUTTON, self.btn2_f )
        self.Bind( wx.EVT_TIMER, self.timer1_f, id=1 )
        self.Bind( wx.EVT_TIMER, self.timer2_f, id=2 )

    def btn1_f( self, event ):
        event.Skip()

    def btn2_f( self, event ):
        event.Skip()

    def timer1_f( self, event ):
        t1 = next_data()
        print("t1     :    ",t1)

    def timer2_f( self, event ):
        t2 = next_data()
        print("t2*****:    ",t2)

app = wx.App()
f = MyFrame1(None)
f.Show(True)
app.MainLoop()

и его вывод такой: 

t2*****:     b'\xb5b\x010\x04\x018\>$GNRMC,063337.00.....$GNGGA...
t1     :     b''
t2*****:     b'\xb5b\x010\x04\x01\x18\>$GNRMC,063338.00.....$GNGGA...
t1     :     b''

и (для прокомментированных двух строк): 

t2*****:    b'$GPGSV,3,1,11,05,43,248,30,07,31,068,12,08,15,048,23,09,16,128,30*7B\r\n'
t1     :    b'$GPGSV,3,2,11,13,42,311,27,15,10,310,18,17,04,157,09,28,70,161,27*72\r\n'

Как видно, t1 не получает данные или t1 просто получает следующее. Я также установил таймеры (100 мс), но тот же выход. Может ли кто-нибудь наставить меня на это, чего мне не хватает?

Ответы [ 2 ]

1 голос
/ 18 апреля 2019

Вам не нужно , нужно , чтобы использовать 2 таймера для периодического сохранения данных.И вам не нужно использовать темы тоже.Просто сохраните переменную-счетчик в своем основном классе Frame (или классе с Timer и сбором данных - ваш пример достаточно прост, что может не потребоваться разбиение) и используйте его, чтобы определить, когда записывать данные.Кроме того: сохраняйте данные, считанные из последовательного порта, в массиве того же класса, чтобы вы могли построить или сохранить их, или что-либо еще:

в MyFrame1.__init__() добавить 

self.last_saved_time = 0
self.plotting = True
self.data = []

Затем в MyFrame1.timer1() do 

 # read and save data
 t1 = next_data()
 self.data.append(t1) # (or do more parsing, convert to numpy arrays, etc

 # send to plotting if it is enabled
 if self.plotting:  
      self.plot_data()

 # save if needed
 now = time.time()
 if (now - self.last_saved_time) > 15:
      self.save_data_to_file()

Опять же, вам не обязательно нужны два таймера или потока.Вы могли бы выполнять построение графика или ввод / вывод в отдельном потоке, но вы идете относительно медленно.

Вероятно, было бы разумнее в конечном итоге разделить код на класс «сборщика данных» со своим собственным циклом обработки событий, а затем перенести его в кадр GUI для построения графика по мере необходимости.Но пример настолько мал, что такой рефакторинг пока не нужен.

0 голосов
/ 18 апреля 2019

Для неблокирующих операций с Gui / wxpython вам нужно использовать потоки, Вы можете использовать wx.lib.delayedresult

или вы можете использовать поточный модуль Python, который я предпочитаю

также, если вам нужно получить текстовые данные из последовательного порта, вы должны декодировать их в utf-8, например: 

ser = serial.Serial('COM9',9600)
try:
    line = ser.readline()
    line = line.decode("utf-8")
except UnicodeDecodeError:
    line = "\ncan't decode from serial, choose different baudrate\n"
    print(line)  # or do whatever you want with line

также это пример чтения последовательного порта с использованием потоков, вы можете использовать его как представление о том, что вы хотите сделать

я добавил пояснительные комментарии в коде 

from threading import Thread
from time import sleep

# you can define a class inherited from Thread class or simply use a function 
class ReadData(Thread):
    def __init__(self):
        super().__init__()
        self.running = True  # used as signal to kill the thread
        self.ser = serial.Serial('COM9',9600)  # open serial

    def run(self):  # run method need to be defined for threading to work
        while self.running:
            print('running')
            sleep(1)
        self.ser.close()

    def read(self):  # reading data from port
        if ser.is_open: 
            try:
                line = ser.readline()
                line = line.decode("utf-8")  # decode data 
            except UnicodeDecodeError:
                line = "\ncan't decode from serial, choose different baudrate\n"
                display(line)
                line = ""

    def kill(self):  # terminate thread safely
        self.running = False

read_data = ReadData()  # define new thread object
read_data.start()  # start the thread

sleep(5)

# in case you want to kill the running thread
print('killing running thread')
read_data.kill()

Edit:

для связи между вашим потоком и основным графическим интерфейсом, т. Е. Вы хотите безопасно передавать последовательные данные, вам следует избегать использования глобальной переменной и использовать вместо этого очереди, вы можете проверить этот ответ и узнать, как их использовать

...