asyncio的性能

Question

我想熟悉asyncio，所以我決定編寫一個數據庫客戶端。但是，性能完全匹配同步代碼。我相信這是我對一個概念的誤解。有人能解釋我在做什麼？

請參見例如下面的代碼：提前

class Connection: 
    def __init__(self, reader, writer, loop): 
     self.futures = deque() 

     # ... 

     self.reader_task = asyncio.async(self.recv_data(), loop=self.loop) 

    @asyncio.coroutine 
    def recv_data(self): 
     while 1: 
      try: 
       response = yield from self.reader.readexactly(4) 
       size, = struct.unpack('I', response) 
       response = yield from self.reader.readexactly(size) 

       # ...     

       future = self.futures.popleft() 

       if not future.cancelled(): 
        future.set_result(response) 

      except Exception: 
       break 

    def send_data(self, data): 
     future = asyncio.Future(loop=self.loop) 
     self.futures.append(future) 

     self.writer.write(data) 

     return future 


loop = asyncio.get_event_loop() 


@asyncio.coroutine 
def benchmark(): 
    connection = yield from create_connection(loop=loop, ...) 

    for i in range(10000): 
     yield from connection.send_data(...) 


s = time.monotonic() 

loop.run_until_complete(benchmark()) 

e = time.monotonic() 
print('Requests per second:', int(10000/(e - s))) 

感謝。

Answer 1

你在撥打電話send_data時出錯了。現在，你有這樣的：

@asyncio.coroutine 
def benchmark(): 
    connection = yield from create_connection(loop=loop, ...) 

    for i in range(10000): 
     yield from connection.send_data(...) 

通過使用yield from裏面的for循環，你就等着future你從send_data返回上移動到下一個呼叫之前產生結果。這使得你的程序基本同步。你想給send_data您的來電，並然後等待結果：

@asyncio.coroutine 
def benchmark(): 
    connection = yield from create_connection(loop=loop, ...) 
    yield from asyncio.wait([connection.send_data(..) for _ in range(10000)]) 

Answer 2

蟒蛇asyncio模塊是單線程：

該模塊提供基礎設施編寫使用協程單線程併發代碼，複用通過套接字和其他資源的I/O訪問，運行網絡客戶端和服務器，以及其他相關的基元。

This question有爲什麼ASYNCIO可以比線程更慢的解釋，但在短：ASYNCIO使用單個線程來執行你的代碼，所以即使你有多個協程，他們都串行執行。線程池用於執行一些回調和I/O。由於GIL，線程還可以串行執行用戶代碼，儘管I/O操作可以同步運行。

使用asyncio的原因並不能改善您對串行執行代碼的改進，因爲事件循環一次只運行一個協程。