python 的Asyncio模块提供了管理事件、协程、任务和线程的方法,以及编写并发代码的原语。此模块的主要组件和概念包括:
本节中重点讨论事件,事实上,异步编程的上下文中,事件无比重要。因为事件的本质就是异步。
1. 什么是事件循环
在计算系统中,可以产生事件的实体叫做事件源,能处理事件的实体叫做事件处理者。
此外,还有一些第三方实体叫做事件循环。它的作用是管理所有的事件,在整个程序运行过程中不断循环执行,追踪事件发生的顺序将它们放到队列中,当主线程空闲的时候,调用相应的事件处理者处理事件。
最后,我们可以通过下面的伪代码来理解事件循环:
所有的事件都在 while 循环中捕捉,然后经过事件处理者处理。事件处理的部分是系统唯一活跃的部分,当一个事件处理完成,流程继续处理下一个事件。
2. 准备工作
Asyncio提供了以下方法来管理事件循环:
1. loop = get_event_loop() : 得到当前上下文的事件循环。
2. loop.call_later(time_delay, callback , arg) : 延后 time_delay 秒再执行 callback 方法。
3. loop.call_soon(callback, argument) : 尽可能快调用 callback, call_soon() 函数结束,主线程回到事件循环之后就会马上调用 callback 。
4. loop.time() : 以float类型返回当前事件循环的内部时间。
5. asyncio.set_event_loop() : 为当前上下文设置事件循环。
6. asyncio.new_event_loop() : 根据此策略创建一个新的事件循环并返回。
7. loop.run_forever() : 在调用 stop() 之前将一直运行。
3. 如何做…
下面的代码中,我们将展示如何使用Asyncio库提供的事件循环创建异步模式的应用。
运行结果如下:
在这个例子中,我们定义了三个异步的任务,相继执行,如下图所示的顺序。
首先,我们要得到这个事件循环:
然后我们通过 call_soon 方法调用了 function_1() 函数。
让我们来看一下 function_1() 的定义:
这个函数通过以下参数定义了应用的异步行为:
1. end_time : 定义了 function_1() 可以运行的最长时间,并通过 call_later 方法传入到 function_2() 中作为参数
2. loop : 之前通过 get_event_loop() 方法得到的事件循环。
function_1() 的任务非常简单,只是打印出函数名字。当然,里面也可以写非常复杂的操作。
任务执行结束之后,它将会比较 loop.time() +1s 和设定的运行时间,如果没有超过,使用 call_later 在1秒之后执行 function_2()
其中 function_2() 和 function_3() 的作用类似。 如果运行的时间超过了设定,事件循环终止。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!