Calling a thread out of scope in python

321 views Asked by At

I have a thread that is defined as in a program that continuously reads serial data along with running a UI in wxpython.

dat = Thread(target=receiving, args=(self.ser,))

The method it calls "receiving" runs in an infinite loop

def receiving(ser):
global last_received
buffer = ''
while True:
    date = datetime.date.today().strftime('%d%m%Y')
    filename1 = str(date) + ".csv"
    while date == datetime.date.today().strftime('%d%m%Y'):
        buffer = buffer + ser.read(ser.inWaiting())
        if '\n' in buffer:
            lines = buffer.split('\n')
            if lines[-2]:
                last_received = lines[-2]
            buffer = lines[-1]
            print_data =[time.strftime( "%H:%M:%S"), last_received]
            try:
                with open(filename1, 'a') as fob:
                    writ = csv.writer(fob, delimiter = ',')
                    writ.writerow(print_data)
                    fob.flush()
            except ValueError:
                with open('errors.log','a') as log:
                    log.write('CSV file writing failed ' + time.strftime("%H:%M:%S")+' on '+datetime.date.today().strftime('%d/%m/%Y')+'\n')
                    log.close()

The argument is defined as

class SerialData(object):

def __init__(self, init=50):
    try:
        serial_list = serialenum.enumerate()
        self.ser = ser = serial.Serial(
            port=serial_list[0],
            baudrate=9600,
            bytesize=serial.EIGHTBITS,
            parity=serial.PARITY_NONE,
            stopbits=serial.STOPBITS_ONE,
            timeout=None,
            xonxoff=0,
            rtscts=0,
            interCharTimeout=None
        )
    except serial.serialutil.SerialException:
        # no serial connection
        self.ser = None
    else:
        dat = Thread(target=receiving, args=(self.ser,))
        if not dat.is_alive:
            dat.start()

def next(self):
    if not self.ser:
        # return anything so we can test when Serial Device isn't connected
        return 'NoC'
    # return a float value or try a few times until we get one
    for i in range(40):
        raw_line = last_received
        try:
            return float(raw_line.strip())
            time.sleep(0.1)
        except ValueError:
            # print 'Not Connected',raw_line
            time.sleep(0.1)
            return 0

Due to a bug in Ubuntu 14.04 the thread hangs after a while. I wanted to periodically check if the thread is alive and start it again if it is not. So I did something like

    def on_timer(self):
    self.text.SetLabel(str(mul_factor*self.datagen.next()))
    if not dat.is_alive():
        dat.start()
    wx.CallLater(1, self.on_timer)

This runs every second to update the data in UI but also needs to check if the thread is not stopped. But this gives me an error saying "NameError: global name 'dat' is not defined". I also tried referring to the thread using the object name path. But didn't work either.

Can someone help me as to how I can start the thread out of scope?

1

There are 1 answers

2
user2751184 On BEST ANSWER

It seems like you want to replace dat with self.dat. dat only exists in the scope of the __init__ method. I suggest reading up on Python scoping rules.