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 条评论
登录 后参与评论

相关文章

来自专栏闻道于事

js登录滑动验证,不滑动无法登陆

js的判断这里是根据滑块的位置进行判断,应该是用一个flag判断 <%@ page language="java" contentType="text/html...

6768
来自专栏陈仁松博客

ASP.NET Core 'Microsoft.Win32.Registry' 错误修复

今天在发布Asp.net Core应用到Azure的时候出现错误InvalidOperationException: Cannot find compilati...

4848
来自专栏我和未来有约会

Kit 3D 更新

Kit3D is a 3D graphics engine written for Microsoft Silverlight. Kit3D was inita...

2526
来自专栏张善友的专栏

Silverlight + Model-View-ViewModel (MVVM)

     早在2005年,John Gossman写了一篇关于Model-View-ViewModel模式的博文,这种模式被他所在的微软的项目组用来创建Expr...

2958
来自专栏张善友的专栏

Mix 10 上的asp.net mvc 2的相关Session

Beyond File | New Company: From Cheesy Sample to Social Platform Scott Hansel...

2547
来自专栏java 成神之路

使用 NIO 实现 echo 服务器

4607
来自专栏大内老A

The .NET of Tomorrow

Ed Charbeneau(http://developer.telerik.com/featured/the-net-of-tomorrow/) Exciti...

31410
来自专栏落花落雨不落叶

canvas画简单电路图

60911
来自专栏张善友的专栏

Miguel de Icaza 细说 Mix 07大会上的Silverlight和DLR

Mono之父Miguel de Icaza 详细报道微软Mix 07大会上的Silverlight和DLR ,上面还谈到了Mono and Silverligh...

2707
来自专栏转载gongluck的CSDN博客

cocos2dx 打灰机

#include "GamePlane.h" #include "PlaneSprite.h" #include "BulletNode.h" #include...

5416

扫码关注云+社区