python如何使用异步异步库 - 行业资讯 - 肥雀云

　　介绍

小编这次要给大家分享的是python如何使用异步异步库,文章内容丰富,感兴趣的小伙伴可以来了解一下,希望大家阅读完这篇文章之后能够有所收获。

<强>在学习asyncio之前,先理清楚同步/异步的概念:

同步是指完成事务的逻辑,先执行第一个事务,如果阻塞了,会一直等待,直到这个事务完成,再执行第二个事务,顺序执行

异步是和同步相对的,异步是指在处理调用这个事务的之后,不会等待这个事务的处理结果,直接处理第二个事务去了,通过状态,通知,回调来通知调用者处理结果

asyncio函数:

异步IO采用消息循环的模式,重复”读取消息,处理消息”的过程,也就是说异步IO模型”需要一个消息循环,在消息循环中,主线程不断地重复”读取消息,处理消息”这一过程。

event_loop事件循环:程序开启一个无限的循环,程序员会把一些函数注册到事件循环上。当满足事件发生的时候,调用相应的协程函数。

协同程序协程:协程对象,指一个使用异步关键字定义的函数,它的调用不会立即执行函数,而是会返回一个协程对象。协程对象需要注册到事件循环,由事件循环调用。

任务任务:一个协程对象就是一个原生可以挂起的函数,任务则是对协程进一步封装,其中包含任务的各种状态。

异步/等待关键字:用于定义协程的关键字,异步定义一个协程,等待用于挂起阻塞的异步调用接口。

下面通过举例来对比同步代码和异步代码编写方面的差异,其次看下两者性能上的差距,使用asyncio.sleep(1)模拟耗时1秒的IO操作。

同步代码:

进口时间
　　
　　def hello ():
　　time . sleep (1)
　　
　　def run ():
　　因为我在范围(5):
　　你好()
　　打印(& # 39;Hello World: % & # 39;% time.time ())
　　if __name__==& # 39; __main__ # 39;:
　　run ()
　　
　　Hello World: 1536842494.2786784
　　Hello World: 1536842495.2796268
　　Hello World: 1536842496.2802596
　　Hello World: 1536842497.2804587
　　Hello World: 1536842498.2812462

异步代码:

进口时间
　　进口asyncio
　　
　　#定义异步函数
　　异步def hello ():
　　打印(& # 39;Hello World: % & # 39;% time.time ())
　　#必须使用等待,不能使用收益率,如果是使用产量,需要采用@asyncio.coroutine相对应
　　等待asyncio.sleep (1)
　　打印(& # 39;你好哇世界:% & # 39;% time.time ())
　　
　　def run ():
　　任务=[]
　　因为我在范围(5):
　　tasks.append (hello ())
　　loop.run_until_complete (asyncio.wait(任务)
　　
　　循环=asyncio.get_event_loop ()
　　if __name__==& # 39; __main__ # 39;:
　　run ()
　　
　　Hello World: 1536855050.1950748
　　Hello World: 1536855050.1950748
　　Hello World: 1536855050.1950748
　　Hello World: 1536855050.1960726
　　Hello World: 1536855050.1960726
　　(暂停约1秒)
　　你好哇世界:1536855051.1993241
　　你好哇世界:1536855051.1993241
　　你好哇世界:1536855051.1993241
　　你好哇世界:1536855051.1993241
　　你好哇世界:1536855051.1993241

异步def用来定义异步函数,其内部有异步操作。每个线程有一个事件循环,主线程调用asyncio.get_event_loop()时会创建事件循环,把异步的任务丢给这个循环的run_until_complete()方法,事件循环会安排协同程序的执行。

上述程序中,Hello()会首先打印出Hello World !,然后,收益率从语法可以让我们方便地调用另一个发电机。

由于等待asyncio.sleep(1)也是一个协同程序,所以线程不会等待asyncio.sleep(1),而是直接中断并执行下一个消息循环。

当asyncio.sleep(1)返回时,线程就可以从收益率从拿到返回值(此处是没有),然后接着执行下一行语句。

把asyncio.sleep(1)看成是一个耗时1秒的IO操作,在此期间,主线程并未等待,而是去执行EventLoop中其他可以执行的协同程序了,因此可以实现并发执行。

异步def hello():定义异步异步函数,中间可以添加等待async.sleep (N)来设定中断并执行下一个循环消息

任务=[]任务则是对协程进一步封装,其中包含任务的各种状态,即多个协同程序函数可以封装成一组任务然后并发执行

循环=asyncio.get_event_loop() #获取“事件循环”对象

loop.run_until_complete (asyncio.wait(任务))#通过事件循环,去调用协程函数

loop.close()结束时间循环

<强>二,aiohttp

如果需要并发http请求,通常是用请求,但请求是同步的库,如果想异步的话需要引入aiohttp。