Почему поток в Python работает асинхронно?

Question

[Morrowind]

Привет!
У меня небольшой затык с потоками Python.
Я использую обычный модуль threading для запуска функции в виде "демона". при старте сервера на Flask.
Сама функция имеет внутри себя еще логику и ряд функции вызываемой этой логикой перемешанных друг с другом.

Получается так что в логе я вижу дикую смесь асинхронных запусков функции все логики которую я прописал.
Протестировав запуск моей функции отдельно по частям и вместе без внесения в threading все отлично работает.

Моя функция делает примерно следующее (ОСТОРОЖНО ПСЕВДОКОД):

def start()
if "файл есть" == 'файл есть':
  while True :
  записываем данные в файл с последней точки (вызываем функцию b1).
else:
 создаем файл (вызываем функцию a1)
 наполняем файл данными (вызываем функцию a2)
 логика проверки даты и времени в записях и т.д. (вызываем функцию a3)
 while True :
    бесконечный цикл наполнения файла последней информацией.(вызываем функцию b1)

flow1 = Thread(target=start, daemon=True)
flow1.start()

Что я вижу в логах при запуске потока: Файла нет -> идет ветка создания файла -> резко в логе появляется информация из логической ветки выше (та где при условии файл есть) О_о и начинает наполнять последними данными. (параллельно идет ветка первичного наполнения файла данными. ) Далее завершая работа функции создания-первичного наполнения и продолжается обычная работа бесконечного цикла по обновлению.
Итог данные тупо перемешиваются в полный хаос, в логах та же беда, а дальше цикл наполняет его нормально как мне нужно.

Хотел бы узнать как управлять этой асинхронностью когда у тебя 1 всего то 1 поток?
Или есть какой то нюанс при работе с внутренними функциями?
Буду благодарен за практические примеры решения подобной проблемы.

Answer 1

[Morrowind]

Решение следущее. Нашел ответ в Как лучше организовать два потока исполнения внутри Flask?

Проблема в том что в Flask уже есть поток и из-за этого происходит вот такая петрушка как у меня. Получается у меня уже 2 потока и Flask уже как то сам крутит ими.

Решение: Сделать в ручную отдельно поток run() и свой

app = Flask(__name__)

@app.route('/')
def hello_world():
    return render_template('index.html')

flow1 = Thread(target=app.run)
flow2 = Thread(target=momowwind, daemon=True)

flow1.start()
flow2.start()

Comments

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

Не стоит использовать во Flask потоки! Flask потокобезопасным не является и рано или поздно в вашем проекте начнут возникать непредсказуемые и труднодиагностируемые ошибки.

[Morrowind]

Сергей Горностаев, Ну а какое решение можно предложить без радикальных ?(Сменить Flask на fast APi< DJANGO или пересмотра архитектуры с нуля). Ведь на сколько я знаю Flask используется командами даже в банках на не больших приложениях и как то не верится что они не используют потоки для тех же демонов.
Возможно есть другое решение о котором я не знаю пока что.

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

Morrowind, Django тоже не потокобезопасный. И в Django, и в Flask потребность в асинхронном фоновом выполнении задач решается с помощью Celery и ей подобных.

Answer 2

[alfss]

1. Запустить все в дебаге и разобраться почему так
   
2. Отказаться от потоков
   
3. Пересмотреть архитектуру решения
   

По псевдокоду проблем не видно, значит реальный код не такой. Или в доп функциях есть циклические вызовы.

Comments

[Morrowind]

Внутри доб функций имеется так же цикл while True, но он крутит конкретный код а не занимается перевызовом еще функций.
Я попробую в ближайшее время более детально показать код.

[Morrowind]

alfss
При пошаговом разбирательстве выяснилось следующее:
При запуске в потоке Thread отдельно без Flask все ок. С логикой функции все в порядке. Таблица наполняется корректно и без проблем с очередностью.

Проблема остается только при запуске потока вместе с стартом сервака flask. Отключив функцию "демона" или включив разницы нет. В логах вижу как будто стартовала функция дважды параллельно.

Я в замешательстве.

Вот обычный main flask-a. Что я упускаю?

app = Flask(__name__)
flow2 = Thread(target=morrowind, daemon=True)
flow2.start()


@app.route('/')
def hello_world():
    return render_template('index.html')


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

[alfss]

Morrowind, а если тред перенести в main?

[Morrowind]

alfss я нашел более топорное решение) Спасибо за помощь)