python async 多线程,python asyncio 实现协程

  python async 多线程,python asyncio 实现协程

  Asyncio ——gather vs wait

  在异步超正析象管(Image Orthicon)中不止可以多次使用阿辛西奥。集合,还有另外一个用法是阿辛西奥。等等,他们都可以让多个协程并发执行。

  那为什么提供2个方法呢?他们有什么区别,适用场景是怎么样的呢?我们先看2个协程的例子:

  asyncdefa():

  打印("暂停")

  awaitasyncio.sleep(3)

  打印(“Resuminga”)

  返回" a "

  asyncdefb():

  打印(暂停)

  awaitasyncio.sleep(1)

  打印(“Resumingb”)

  返回" b "在分析里面用聚集执行一下:

  In:return_value_a,return _ value _ b=awaitasyncio。gather(a(),b())

  暂停a

  暂停b

  结果b

  Resuminga

  在:年返回值一,返回值b

  Out:(A , B )好了,asyncio.gather方法的名字说明了它的用途,集合的意思是「搜集」,也就是能够收集协程的结果,而且要注意,它会按输入协程的顺序保存的对应协程的执行结果。

  接着我们说等待,先执行一下:

  In:done,pending=awaitasyncio.wait([a(),b()])

  暂停b

  暂停a

  结果b

  Resuminga

  In:done

  Out:

  {Taskfinishedcoro=a()done,definedatipython-input-5-5ee 142734d 16:1 result= A ,

  Taskfinishedcoro=b()done,definedatipython-input-5-5ee 142734d 16:8 result= B }

  在:年待定

  Out:set()

  In:task=list(done)[0]

  In:task任务任务

  out :任务完成coro=B()done,definedatipython-input-5-5ee 142734d 16:8 result= B

  In:task.result()

  Out:Basyncio。等等的返回值有2项,第一项表示完成的任务列表(完成),第二项表示等待(未来)完成的任务列表(待定),每个任务都是一个工作实例,由于这2个任务都已经完成,所以可以执行task.result()获得协程返回值。

  好吧,说到这里,总结下它俩的区别的第一层区别:

  strong>

  asyncio.gather封装的Task全程黑盒,只告诉你协程结果。

  asyncio.wait会返回封装的Task(包含已完成和挂起的任务),如果你关注协程执行结果你需要从对应Task实例里面用result方法自己拿。

  为什么说「第一层区别」,asyncio.wait看名字可以理解为「等待」,所以返回值的第二项是pending列表,但是看上面的例子,pending是空集合,那么在什么情况下,pending里面不为空呢?这就是第二层区别:asyncio.wait支持选择返回的时机。

  asyncio.wait支持一个接收参数return_when,在默认情况下,asyncio.wait会等待全部任务完成(return_when='ALL_COMPLETED'),它还支持FIRST_COMPLETED(第一个协程完成就返回)和FIRST_EXCEPTION(出现第一个异常就返回):

  

In:done,pending=awaitasyncio.wait([a(),b()],return_when=asyncio.tasks.FIRST_COMPLETED)

看到了吧,这次只有协程b完成了,协程a还是pending状态。

 

  在大部分情况下,用asyncio.gather是足够的,如果你有特殊需求,可以选择asyncio.wait,举2个例子:

  需要拿到封装好的Task,以便取消或者添加成功回调等

  业务上需要FIRST_COMPLETED/FIRST_EXCEPTION即返回的

  asyncio.create_task vs loop.create_task vs asyncio.ensure_future

  创建一个Task一共有3种方法,如这小节的标题。在上篇文章我说过,从Python 3.7开始可以统一的使用更高阶的asyncio.create_task。其实asyncio.create_task就是用的loop.create_task:

  

defcreate_task(coro):

loop.create_task接受的参数需要是一个协程,但是asyncio.ensure_future除了接受协程,还可以是Future对象或者awaitable对象:

 

  如果参数是协程,其实底层还是用的loop.create_task,返回Task对象

  如果是Future对象会直接返回

  如果是一个awaitable对象会await这个对象的__await__方法,再执行一次ensure_future,最后返回Task或者Future

  所以就像ensure_future名字说的,确保这个是一个Future对象:Task是Future 子类,前面说过一般情况下开发者不需要自己创建Future

  其实前面说的asyncio.wait和asyncio.gather里面都用了asyncio.ensure_future。对于绝大多数场景要并发执行的是协程,所以直接用asyncio.create_task就足够了~

  下一节:深究Python中的asyncio库-shield函数

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: