历史网安卓

座 机:历史网首页
手 机:13842593595

公司新闻

您现在的位置:历史网 > 历史知识 > 正文

Python 的异步 IO:Asyncio 简介

历史网 发布时间:2019-06-12 浏览:131次

  在历史上和现实中,经济所之所以能够成为吸引人才的好地方,一个重要的原因就在于,经济所人是以学术立身的,尊重知识,尊重人才,以人才为中心。让真正的人才在经济所能够得到最好的尊重,不仅是经济所人的一种文化传承,而且是经济所延续90年的学术生态。  所有这些,既可以说是经济所的特质,也可以说是经济所人的精神。

  原来中国99A才是真正的深藏不露……是那些所谓的“世界坦克排行榜”的榜单是不是可以重新更正一下排名了?(本文为*****军事原创,作者邵广鑫。

Python 的异步 IO:Asyncio 简介

的asyncio类似于C++的。 异步IO,就是你发起一个IO操作,不用等它结束,可以继续做其他事情,当它结束时,你会得到通知。 是并发(concurrency)的一种方式。

对来说,并发还可以通过线程(threading)和多进程(multiprocessing)来实现。 并不能带来真正的并行(parallelism)。 当然,因为GIL(全局解释器锁)的存在,Python的多线程也不能带来真正的并行。

可交给asyncio执行的任务,称为协程(coroutine)。

一个协程可以放弃执行,把机会让给其它协程(即yieldfrom或await)。

定义协程协程的定义,需要使用asyncdef语句。

do_some_work便是一个协程。

准确来说,do_some_work是一个协程函数,可以通过来验证:这个协程什么都没做,我们让它睡眠几秒,以模拟实际的工作量:在解释await之前,有必要说明一下协程可以做哪些事。

协程可以:也是一个协程,所以(x)就是等待另一个协程。 可参见的文档:运行协程调用协程函数,协程并不会开始运行,只是返回一个协程对象,可以通过来验证:此处还会引发一条警告:要让这个协程对象运行的话,有两种方式:简单来说,只有loop运行了,协程才可能运行。 下面先拿到当前线程缺省的loop,然后把协程对象交给_until_complete,协程对象随后会在loop里得到运行。 run_until_complete是一个阻塞(blocking)调用,直到协程运行结束,它才返回。

这一点从函数名不难看出。 run_until_complete的参数是一个future,但是我们这里传给它的却是协程对象,之所以能这样,是因为它在内部做了检查,通过ensure_future函数把协程对象包装(wrap)成了future。 所以,我们可以写得更明显一些:完整代码:运行结果:回调假如协程是一个IO的读操作,等它读完数据后,我们希望得到通知,以便下一步数据的处理。

这一需求可以通过往future添加回调来实现。

多个协程实际项目中,往往有多个协程,同时在一个loop里运行。

为了把多个协程交给loop,需要借助函数。

或者先把协程存在列表里:运行结果:这两个协程是并发运行的,所以等待的时间不是1+3=4秒,而是以耗时较长的那个协程为准。

参考函数gather的文档:发现也可以传futures给它:gather起聚合的作用,把多个futures包装成单个future,因为_until_complete只接受单个future。

run_until_complete和run_forever我们一直通过run_until_complete来运行loop,等到future完成,run_until_complete也就返回了。

输出:现在改用run_forever:输出:三秒钟过后,future结束,但是程序并不会退出。 run_forever会一直运行,直到stop被调用,但是你不能像下面这样调stop:run_forever不返回,stop永远也不会被调用。

所以,只能在协程中调stop:这样并非没有问题,假如有多个协程在loop里运行:第二个协程没结束,loop就停止了——被先结束的那个协程给停掉的。 要解决这个问题,可以用gather把多个协程合并成一个future,并添加回调,然后在回调里再去停止loop。

其实这基本上就是run_until_complete的实现了,run_until_complete在内部也是调用run_forever。

CloseLoop以上示例都没有调用,好像也没有什么问题。

所以到底要不要调呢?简单来说,loop只要不关闭,就还可以再运行。 :但是如果关闭了,就不能再运行了:建议调用,以彻底清理loop对象防止误用。 和功能相似。 具体差别可请参见StackOverflow的讨论:。 TimerC++提供了IO对象timer,但是Python并没有原生支持timer,不过可以用模拟。

上一篇:【蟹粉肉包子】初试中式面点收获满满

下一篇:没有了