如何利用Python的异步和定时任务来提高程序的并发性和执行效率？

WBOY

发布时间：2023-05-09 17:25:16

1267人浏览过

来源于亿速云

转载

异步任务和定时任务

对于 web 应用中的一些操作，它们可能需要较长时间才能完成，或者它们的执行时间无法确定。对于这些操作，如果用户只需要知道服务器已经接收到了请求，而不需要立即得到请求的执行结果，那么我们就可以将它们进行异步化处理。如果说使用缓存是优化网站性能的第一要义，那么将耗时或执行时间不确定的任务异步化则是网站性能优化的第二要义。简单来说，能够推迟做的事情都不应该马上去做。

在上一章节中，我们以发送短信和上传文件到云存储为例。这两个操作中，前者属于时间不确定的操作（因为作为调用者，我们无法确定三方平台响应的时间），后者属于耗时的操作（如果文件较大或者三方平台不稳定，都可能导致上传的时间较长）。很显然，这两个操作都可以进行异步化处理。

在 Python 项目中，我们可以使用多线程或借助三方库 Celery 来实现异步化处理。

使用Celery实现异步化

Celery 是一个 Python 的异步任务队列/消息队列，它可以很方便地完成异步任务的处理。使用 Celery 可以将任务分发到多个任务执行者中，任务执行者可以是单个进程或多个进程、多个主机。Celery 还支持任务的优先级、任务结果的保存、任务的重试等功能。

使用 Celery 实现异步化需要以下步骤：

立即学习“Python免费学习笔记（深入）”；

安装 Celery

pip install celery

在项目中创建一个 Celery 应用

from celery import Celery
app = Celery('tasks', broker='pyamqp://guest@localhost//')

定义任务

@app.task
def add(x, y):
    return x + y

在项目中调用任务

result = add.delay(4, 4)
print(result.get(timeout=1))

使用多线程实现异步化

Python 中的 threading 模块可以用来创建多线程。使用多线程可以将耗时的任务放在新线程中执行，从而不会影响主线程的执行。

使用多线程实现异步化需要以下步骤：

导入 threading 模块

import threading

定义一个函数作为任务

def task():
    print('Hello from task')

创建一个新线程并启动它

t = threading.Thread(target=task)
t.start()

定时任务

有些任务需要在特定的时间执行，这时候我们需要使用定时任务。Python 中有多个第三方库可以用来实现定时任务，如 schedule、APScheduler 等。下面以 APScheduler 为例来讲解如何实现定时任务。

使用 APScheduler 实现定时任务需要以下步骤：

安装 APScheduler

pip install apscheduler

导入 APScheduler 模块

from apscheduler.schedulers.blocking import BlockingScheduler

创建一个 BlockingScheduler 实例并添加任务

def task():
    print('Hello from task')
scheduler = BlockingScheduler()
scheduler.add_job(task, 'interval', seconds=5)
scheduler.start()

上述代码会每隔 5 秒执行一次 task 函数。

Celery和多线程的比较

虽然 Celery 和多线程都可以实现异步化处理，但是它们之间存在一些差异和优缺点。

佳蓝在线销售系统(创业版) 佳蓝在线销售

1、对ASP内核代码进行DLL封装，从而大大提高了用户的访问速度和安全性；2、采用后台生成HTML网页的格式，使程序访问速度得到进一步的提升；3、用户可发展下级会员并在下级购买商品时获得差额利润；4、全新模板选择功能；5、后台增加磁盘绑定功能；6、后台增加库存查询功能；7、后台增加财务统计功能；8、后台面值类型批量设定；9、后台财务曲线报表显示；10、完善订单功能；11、对所有传输的字符串进行安全

下载