python如何定时异步执行任务

昨天,我们介绍了在python3.5之后,对asyncio的操作,也初步认识了如何才能对网络进行异步请求。

今天我们就来讲下如何定时调用任务。

即刻生效

还记得昨天的 run_until_complete 吗,今天我们换个函数来用,call_soon

call_soon 支持在下一次事件循环的迭代中执行提供的回调函数。回调函数只能传递位置参数,如果想指定关键字参数的话,可以使用 functools.partial 函数来辅助使用。

import asyncio
import functools

# 下面我们将借助partial函数来说明如何使用关键字参数
def callback(arg, *, kwarg='default'):
    print(f'callback with {arg} and {kwarg}')

async def main(loop):
    print('register callbacks')
    # 还是通过get_event_loop 获取Eventloop
    loop.call_soon(callback, 1)
    # 使用partial函数,对kwarg参数进行控制
    wrapped = functools.partial(callback, kwarg='not default')
    loop.call_soon(wrapped, 2)
    # 上一篇中说过的,await用于等待,sleep也不是time.sleep
    await asyncio.sleep(0.1)

event_loop = asyncio.get_event_loop()
try:
    print('entering event loop')
    event_loop.run_until_complete(main(event_loop))
finally:
    print('closing event loop')
    event_loop.close()

对于partial函数不熟悉的同学,可以移步《不会用partial,别说你会python

执行结果如下:

延迟执行

可以使用 call_later 方法实现延迟多少秒后执行回调函数。call_later 的第一个参数是延迟多少秒,第二个参数是回调函数,后面的参数是回调函数的位置参数

import asyncio

def callback(n):
    print(f'callback with {n}')

async def main(loop):
    print('register callbacks')
    # 延迟0.2秒执行
    # 执行完后调用callback函数
    # callback的参数n
    loop.call_later(0.2, callback, 1)
    loop.call_later(0.1, callback, 2)
    # 再来看下和call_soon的区别
    loop.call_soon(callback, 3)

    await asyncio.sleep(0.4)

event_loop = asyncio.get_event_loop()
try:
    print('starting event_loop')
    event_loop.run_until_complete(main(event_loop))
finally:
    print('closing event_loop')
    event_loop.close()

执行结果如下:

指定时间执行

可以使用 call_at 方法实现在将来指定的某个时间执行回调函数。call_at 的第一个参数是执行的时间点,第二个参数是回调函数,后面的参数是回调函数的位置参数。有一点需要注意的是不要使用 time 或 datetime 模块的时间点,而是要使用 loop.time() 获取当前时间。

import asyncio
import time

def callback(n, loop):
    print(f'callback with {n} at {loop.time()}')

async def main(loop):
    # 使用loop.time 而不是time和datetime模块
    now = loop.time()
    print(f'time模块的时间: {time.time()}')
    print(f'loop.time的时间: {now}')

    print('register callbacks')
    # 使用call_at指定当前时间后的0.2秒执行
    # 执行完了回掉callback
    # callback的n和loop参数
    loop.call_at(now + 0.2, callback, 1, loop)
    loop.call_at(now + 0.1, callback, 2, loop)
    # 和call_soon对比一下
    loop.call_soon(callback, 3, loop)

    await asyncio.sleep(1)


event_loop = asyncio.get_event_loop()
try:
    print('starting event_loop')
    event_loop.run_until_complete(main(event_loop))
finally:
    print('closing event_loop')
    event_loop.close()

执行结果如下:

好啦,今天的内容就到这了,所有的代码都已上传至我的github中。

github:https://github.com/MiracleYoung/exercises

如果你对今天的内容还感兴趣的话,何不点个赞再走呢?如果感兴趣到想赞赏我,就不要犹豫啦~

原文发布于微信公众号 - 猿媛牧场(xpchuiit)

原文发表时间:2018-06-13

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏数据结构与算法

P2085 最小函数值(minval)

题目描述 有n个函数,分别为F1,F2,...,Fn。定义Fi(x)=Aix^2+Bix+Ci (x∈N*)。给定这些Ai、Bi和Ci,请求出所有函数的所有函数...

3085
来自专栏软件开发 -- 分享 互助 成长

C++ STL之迭代器注意事项

1、两个迭代器组成的区间是前闭后开的 2、如果迭代器的有效性,如果迭代器所指向的元素已经被删除,那么迭代器会失效 http://blog.csdn.net/hs...

1735
来自专栏猿人谷

成员以其在类中声明的顺序构造

分析以下代码的输出: #include<iostream> using namespace std; class A { public: A(int j):...

1756
来自专栏Albert陈凯

4.2 创建RDD

4.2 创建RDD 由于Spark一切都是基于RDD的,如何创建RDD就变得非常重要,除了可以直接从父RDD转换,还支持两种方式来创建RDD: 1)并行化一个...

2959
来自专栏null的专栏

Linux C 编程——多线程

线程是计算机中独立运行的最小单位,运行时占用很少的系统资源。与多进程相比,多进程具有多进程不具备的一些优点,其最重要的是:对于多线程来说,其能够比多进程更加节省...

2586
来自专栏Deep learning进阶路

C++随记(一)---字符串数组的输入问题

首先来看一段程序: #include<iostream> using namespace std; int main(){ char name[10],s...

1730
来自专栏Python小屋

Python编写只允许实例化一个对象的类

>>> class T: __total = 0 def __init__(self, value): if T.__total != 0: r...

3138
来自专栏云霄雨霁

查找----基于无序链表

1290
来自专栏海天一树

小朋友学Python(27):全局变量的引用和修改

一、引用 例1 a = 1 def func(): if 1 == a: print("a = %d" % a) if __name__...

2657
来自专栏Deep learning进阶路

C++随记(二)---动态分配内存问题(1)

C++随记(二)---动态分配内存问题(1) 面向对象的编程的一个特点就是在运行阶段(而不是编译阶段)进行决策。运行阶段决策提供了灵活性,可以根据当时的情况进行...

1690

扫码关注云+社区