''

def _run(self):

    is_normal = True
    while self._is_alive:
        try:
            number = self.ser.in_waiting
        except serial.SerialException:
            is_normal = False
            self._is_alive = False
            break
        else:
            if (number > 0):
                text = self.ser.read(number)
                text = text.decode(u'utf-8', u'replace')
                self._msg_queue.put(text)
    if is_normal:
        self.ser.close()
