Python中的导入类中运行线程

class serialworker():
    """This Class instantiates a serial thread and has functions for facilitating communication
    to the serial interface as well as some GSM900 specific functions"""
​
    def __init__(self, port='/dev/ttyAMA0', baud=115200, timeout=5, pollspeed=0.1):
        """Initialises the variables used in this class, baud=, timeout= and pollspeed= can be adjusted
        But have initial values of 115200, 5 and 0.1 respectively, in the future i could add stopbits and parity here"""
​
        self.port = port
        self.baud = baud
        self.timeout = timeout
        self.pollspeed = pollspeed
        self.run = False
        self.ser = serial.Serial
​
        """Command variable description:
        self.command        = Command to write in next while cycle
        self.commandwait    = Bool used to determine if write buffer contains a command for writing in the next while cycle
        self.commandstat    = Variable used to hold the return status of the command that was submitted
        self.commandret     = Bool used to determine if a command was written to the buffer, as to allow the output to be read in the next while cycle
        self.respwait       = Bool used to determine if commandstat is ready to be read
        """
        self.command = ""
        self.commandwait = False
        self.commandstat = ""
        self.commandret = False
        self.respwait = False
        self.lock = threading.Lock()
​
    def start(self):
        """Starts a thread of the _readwriteloop() funtion"""
        #TODO add thread checking, only 1 thread per serial interface should be allowed
​
        self.run = True
        t1 = threading.Thread(target=self.readwriteloop())
        t1.start()
        print("started")
​
    def checkgsm900online(self):
        """Checks if the GSM900 board is online"""
        with self.lock:
            gsmser = serial.Serial(
            port=self.port,
            baudrate=self.baud,
            parity=serial.PARITY_NONE,
            stopbits=serial.STOPBITS_ONE,
            bytesize=serial.EIGHTBITS,
            timeout=self.timeout,)
            gsmcheck = ("AT"+"\r\n").encode()
            gsmser.write(gsmcheck)
            sleep(0.03)
            gsmbuffer = gsmser.inWaiting()
            if gsmbuffer == 0:
                gsmser.flush()
                gsmser.close()
                return False
            else:
                gsmser.flush()
                gsmser.close()
                return True
​
    def check(self):
        """Checks if a thread currently exists"""
​
        return self.run
​
    def stop(self):
        """stops running thread"""
​
        with self.lock:
            self.run = False
​
    def inputcommand(self, string, flag):
        """Allows for a single command to be inputted, sets the commandwait to true to tell the loop to check its queue.
        Optionally you can set flag=False to not wait for a return stat on this command"""
​
        with self.lock:
            self.command = (string+"\r\n").encode()
            self.commandwait = True
            print("waiting for resp")
            if flag:
                while not self.respwait:
                    sleep(0.1)
                self.respwait = False
                return self.commandstat
​
    def readwriteloop(self):
        """Main function of the class that reads serial data from a buffer
        And checks for new commands inputted by the inputcommand() function
        which output status it will write to the commandstat buffer"""
        #TODO write function for retrieving input command return data not just the status
​
        ser = self.ser(
        port=self.port,
        baudrate=self.baud,
        parity=serial.PARITY_NONE,
        stopbits=serial.STOPBITS_ONE,
        bytesize=serial.EIGHTBITS,
        timeout=self.timeout,)
        while self.run:
            with self.lock:
                ser.inWaiting()
                buffer = ser.inWaiting()
                if buffer != 0:
                    decodeline = ser.readline().decode('utf-8', "ignore").rstrip('\n')
                    if len(decodeline) > 2:
                        if self.commandret:
                            if 'ERROR' in decodeline:
                                self.commandstat = decodeline
                                self.commandret = False
                                self.respwait = True
                            elif 'OK' in decodeline:
                                self.commandstat = decodeline
                                self.commandret = False
                                self.respwait = True
                            elif 'NO CARRIER' in decodeline:
                                self.commandstat = decodeline
                                self.commandret = False
                                self.respwait = True
​
                if self.commandwait:
                    ser.write(self.command)
                    #print(self.command)
                    self.commandwait = False
                    self.commandret = True
            sleep(self.pollspeed)