python3 async await（python中使用asyncio实现异步IO）

1 
    
    
   、说明

Python实现异步IO非常简单 
    
    
   ，asyncio是Python 3.4版本引入的标准库
     


     


     

，直接内置了对异步IO的支持    
    
    
。

asyncio的编程模型就是一个消息循环  


     


     


   。我们从asyncio模块中直接获取一个EventLoop的引用 




 




 




，然后把需要执行的协程扔到EventLoop中执行 

   

   

  ，就实现了异步IO


 




 




 

。

2
     


     


     

、实例

importasyncio @asyncio.coroutine defwget(host): print(wget%s...%host) connect=asyncio.open_connection(host,80) reader,writer=yieldfromconnect header=GET/HTTP/1.0\r\nHost:%s\r\n\r\n%host writer.write(header.encode(utf-8)) yieldfromwriter.drain() whileTrue: line=yieldfromreader.readline() ifline==b\r\n: break print(%sheader>%s%(host,line.decode(utf-8).rstrip())) #Ignorethebody,closethesocket writer.close() loop=asyncio.get_event_loop() tasks=[wget(host)forhostin[www.sina.com.cn,www.sohu.com,www.163.com]] loop.run_until_complete(asyncio.wait(tasks)) loop.close()