Maison >développement back-end >Tutoriel Python >Comment utiliser Python Flask pour créer des applications API efficaces et implémenter des tâches en arrière-plan
En Python, il existe plusieurs solutions pour implémenter des tâches en arrière-plan, comme Celery ou Redis Queue, qui sont de bons moyens d'implémenter un système de file d'attente de tâches. Mais utiliser les deux est fastidieux. Imaginez un scénario dans lequel nous utilisons Flask pour créer une API permettant d'appeler des tâches en arrière-plan à partir d'un terminal et d'arrêter les tâches en arrière-plan à l'aide d'un autre terminal.
Création d'une API simple à l'aide de Flask, avec deux méthodes principales, une pour démarrer la tâche en arrière-plan et l'autre pour l'arrêter.
Pour gérer le cycle de vie des tâches, nous utilisons des Event Objects
, qui est un simple mécanisme de communication inter-thread. Event Objects
,这是一种简单的线程间通信机制。
如下所示是所需导入的库、线程事件声明和后台任务方法:
from time import sleep from flask import Flask from flask_cors import CORS import threading thread_event = threading.Event() def backgroundTask(): while thread_event.is_set(): print('Background task running!') sleep(5)
这里的关键是is_set()
方法,它将返回内部线程事件标志的值:true
或false
。
首先,使用set()
方法把标志设置为true
,它将启动一个线程,并连续运行backgroundTask
方法。
@app.route("/start", methods=["POST"]) def startBackgroundTask(): try: thread_event.set() thread = threading.Thread(target=backgroundTask) thread.start() return "Background task started!" except Exception as error: return str(error)
如果要停止任务,调用clear()
方法将标志设置为false
@app.route("/stop", methods=["POST"]) def stopBackgroundTask(): try: thread_event.clear() return "Background task stopped!" except Exception as error: return str(error)🎜La clé ici est la méthode
is_set()
, qui renverra la valeur de l'indicateur d'événement du thread interne : true
ou false
. 🎜🎜Tout d'abord, utilisez la méthode set()
pour définir l'indicateur sur true
, ce qui démarrera un thread et exécutera la méthode backgroundTask
en continu. 🎜rrreee🎜Si vous souhaitez arrêter la tâche, appelez la méthode clear()
pour définir l'indicateur sur false
afin d'arrêter le thread en cours d'exécution. 🎜rrreeeCe qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!