Как запустить функцию и не дожидаясь ее завершения продолжить работу основной программы?

Question

[Klaud111]

Суть такая, есть скрипт, использующий Flask, в функции main(), при определенном условии запускается функция function(). Мне нужно, чтобы при вызове эта функция начала работу, но при этом функция main вернула значение value не дожидаясь завершения function(). Я так понял, нужно асинхронное программирование использовать. Пытался использовать asyncio, но мне не помогло.

import ...
app = Flask(__name__)
logging.basicConfig(level=logging.DEBUG)
@app.route("/", methods=['POST', 'GET'])
def main():
	
	value = a + b
        if value >=2:
                fucntion()
	return value

app.run()

Comments

[Иван]

Использовать модули threading/multiprocessing ну и да, async?

[Klaud111]

Иван, threading я использовал, не помогло. А подсказать кодом, можете если не сложно?

Answer 1

[pcdesign]

Если делать по-человечески, то конечно Celery.

Но если вы не хотите с Celery городить огород и вам главное запустить фукнцию, то вы можете вынести ее в отдельный файл и запустить его через subprocess

Для примера два файла положите их рядом.
run.py

from flask import Flask
import subprocess

app = Flask(__name__)


@app.route("/")
def main():
    subprocess.Popen('python mysleep.py', shell=True, executable='/bin/bash')
    return "Hello"


if __name__ == '__main__':
    app.run(debug=True, host='0.0.0.0')

mysleep.py

import time

time.sleep(10)
print("zzzzzzzzzzzz")

Comments

[Klaud111]

Вроде это я тоже использовал. И опять же сначала, программа ждала завершение субпроцесса, а потом возвращала значение. Но это не точно. Библиотека так и называется?

[pcdesign]

Klaud111, я изменил свой ответ.
Попробуйте.
Ждать завершения не надо.

[Klaud111]

pcdesign, естественно попробую, но пока у меня вопрос. Я с питоном недавно начала работать, и тем более с Flask, можете объяснить мне, зачем нужна строчка if __name__ == '__main__':. Почему нельзя просто app.run указать? Вроде как здесь указывается если "имя файла main".

[pcdesign]

Klaud111, Для чего и зачем нужен def main() в python?

[Klaud111]

Спасибо, и за subprocess, и за if __name__., помогло.

[Klaud111]

Не подскажите, как передать переменные в субпроцесс и потом их использовать в нем?

[pcdesign]

Klaud111,
Да можно по разному, например так:

a = 1
b = 2
cmd = 'python mysleep.py {} {}'.format(a, b)
subprocess.Popen(cmd, shell=True, executable='/bin/bash')

А получить в файле mysleep.py так:

import sys

arr = sys.argv[1:]
print(arr)

[Сергей Горностаев]

Klaud111, пишите сразу адрес сервера, использующего этот код, проверим за сколько секунд его можно завалить, просто зажав F5.

Answer 2

[Сергей Горностаев]

Flask спроектирован однопоточным и синхронным, использование многопоточности или асинхронности может привести к проблемам. Используйте Celery и тому подобное.

Comments

[Klaud111]

Django я так понимаю подойдет?

[Сергей Горностаев]

Klaud111, он тоже синхронный и однопоточный. В django-приложениях для таких задач тоже применяют Celery.