问通过异步队列发送确认消息

EN

    import asyncio
    import Parser

    class Communicator(asyncio.Protocol):
        def __init__(self, received_queue, transmit_queue):
            super().__init__()
            self.buffer = None
            self.transport = None
            self.parser = Parser()
            self.table = Table(self)
            self.received_queue = received_queue
            self.transmit_queue = transmit_queue

        def connection_made:
            # Code to setup connect

        async def ack_msg():
            # Acknowledment message code

        def data_received(self, line:
            for line in lines[:-1]:
                self.parser.parse_message(line, self.transport)

received_queue = asyncio.Queue()
transmit_queue = asyncio.Queue()
 communicator_partial = partial(Communicator, received_queue, transmit_queue)
loop = asyncio.get_event_loop()
communicator = serial_asyncio.create_serial_connection(loop, communicator_partial, '/dev/ttys005', baudrate=115200) 
asyncio.ensure_future(print_received(loop, received_queue))
asyncio.ensure_future(read_prompt(loop, transmit_queue, communicator_partial))
loop.run_forever()
loop.close()

    import Table

    class Parser():
        def __init__(self, communicator):
            self.table = Table(communicator)

        def parse_message():
            # Code to cute the address from String
            self.table.add_address(source)

    import asyncio

    class Table()
        def __init__(self, communicator):
            self.table = dict()
            self.communicator = communicator

        async def add_address(self, address, hop, metric):
            if address not in self.routing_table:
                self.routing_table[address] = Node(address)
                await self.communicator.transmit_queue.put(self.communicator.ack_msg())