python异步任务

- 日理万妓 2022-09-11 03:11 248阅读 0赞

需求及场景:
在查询进度值接口中,客户端会几秒钟获取一次进度值,但如果,客户端关闭,就不在主动查询进度值了。python脚本在调用启动任务脚本后,开始查询进度值,那么在调用启动脚本后,用异步函数,实现n秒钟查询一次更新中的进度值,进度完成后,更新状态到数据库,以备下次客户端获取某条数据的状态。
异步函数demo实现如下:

  1. # -*- coding:utf-8 -*-
  2. from threading import Thread
  3. # 自定义装饰器
  4. def my_async(fn):
  5. def wrapper(*args, **kwargs):
  6. Thread(target=fn, args=args, kwargs=kwargs).start()
  7. return wrapper
  8. # 自定义装饰器
  9. @my_async
  10. def get_data():
  11. return 'async_data'
  12. def get_name():
  13. return 'zhang_san'
  14. if __name__ == '__main__':
  15. print(get_data())
  16. print(get_name())
  17. print('1')
  18. print('2')
  19. print('3')
  20. print('4')
  21. print('5')
  22. # 执行结果
  23. zhang_san
  24. 1
  25. 2
  26. 3
  27. 4
  28. 5
  29. async_data

发表评论

表情:
评论列表 (有 0 条评论,248人围观)

还没有评论,来说两句吧...

相关阅读

    相关 python异步任务

    需求及场景: 在查询进度值接口中,客户端会几秒钟获取一次进度值,但如果,客户端关闭,就不在主动查询进度值了。python脚本在调用启动任务脚本后,开始查询进度值,那么在调用

    相关 python + Flask 执行异步任务

    在使用Flask开发python的web应用时,可能会遇到需要较长时间处理的任务,此时就需要使用异步的方式来实现,让长时间任务在后台运行,先将本次请求的响应状态返回给前端,不然