1. import _thread
    2. import utime
    3. from machine import UART
    4. from queue import Queue
    6. class Example_uart(object):
    7.     def __init__(self, no=UART.UART2, bate=115200, data_bits=8, parity=0, stop_bits=1, flow_control=0):
    8.         self.uart = UART(no, bate, data_bits, parity, stop_bits, flow_control)
    9.         self._queue = Queue(5)
    10.         _thread.start_new_thread(self.handler_thread, ())
    11.         self.uart.set_callback(self.callback)
    15.     def callback(self, para):
    16.         print("call para:{}".format(para))
    17.         if(0 == para[0]):
    18.             self._queue.put(para[2])
    20.     def uartWrite(self, msg):
    21.         print("write msg:{}".format(msg))
    22.         self.uart.write(msg)
    24.     def uartRead(self, len):
    25.         msg = self.uart.read(len)
    26.         utf8_msg = msg.decode()
    27.         print("UartRead msg: {}".format(utf8_msg))
    28.         return utf8_msg
    30.     def uartWrite_test(self):
    31.         for i in range(10):
    32.             write_msg = "Hello count={}".format(i)
    33.             self.uartWrite(write_msg)
    34.             utime.sleep(1)
    36.     def handler_thread(self):
    37.         while True:
    38.             recv_len = self._queue.get()
    39.             self.uartRead(recv_len)
    41. if __name__ == "__main__":
    42.     uart_test = Example_uart()
    43.     uart_test.uartWrite_test()