Как добавить синхронность в асинхронный код?

Question

[Herben]

У меня есть асинхронный телеграм бот, мне нужно, чтобы условно функция 1 выполнялась по очереди её вызовов, то есть 3 пользователя её вызвали и каждый получит от неё ответ синхронно, сначала 1 получит ответ, потом 2 и 3, но чтобы при этом не блокировались от выполнения другие асинхронные функции, как это можно реализовать?

Примерный код:

import asyncio

async def first():
    print('321')
    await asyncio.sleep(1)
    print('123')

def second(): #Эта функция не будет отвечать пока не ответ предыдущему вызвавшему её
    pass #Тут должны быть какие-то действия

async def third():
    print('123')
    await asyncio.sleep(1)
    print('321')

Думаю, понятно объяснил идею

Всё что я нашёл это: https://stackoverflow.com/questions/43241221/how-c...
но я глянул ответы и понял, что ничего не понял
(простите если туплю)

Заранее огромное спасибо!

Answer 1

[Vindicar]

Ну во-первых, задумайся: что значит "три пользователя её вызвали"?
Время доставки пакета по сети неравномерно. Первый пользователь мог нажать "Отправить" чуть раньше, но его сообщение будет доставлено после второго. Так что вопрос обеспечения корректного порядка УЖЕ непрост.
Далее, ключевая идея аснихронности как раз в том, что во время паузы в обслуживании одного запроса мы можем заниматься другим запросом.

Включая режим Ванги, я могу предположить, что в твоём боте используются глобальные переменные для хранения данных, и ты споткнулся о ситуацию, когда при приходе двух близких по времени запросов их значения перезаписываются. И вместо того, чтобы это исправить с помощью организации данных как хранилища ключ-значение (ид пользователя - сохранённые данные), ты пытается поставить пользователей в очередь.

Comments

[Herben]

Три пользователя её вызвали это пример, что ну, три пользователя её и вызвали, про порядок это был пример для понимания, понятно, что кто первый достучится это рандом.

Нету у меня глобальных переменных, казус в том, что пока происходит 2 функция происходит куча махинаций с бд и прочим кодом. Боюсь пока эта функция не успеет закончится у 1, её вызовет 2 и в итоге в бд махинации 1 пользователя пойдут по одному месту, что испортит результат этой функции остальным, кто её запросит.

[Vindicar]

Herben, используй транзакции БД, может быть?

[Herben]

Vindicar, так я их и использовал. В общем, во 2 функции бд берёт из таблицы с юзерами из определенного столбца самое высокое значение, плюсует к нему 1 и выдаёт вызвавшему ему и существующему пользователю в бд пользователю. (update, не insert и это не idшник юзера)

Я боюсь того, что кто-то тоже вызовет её пока 1 сохранение не успело комитнуться и в итоге у обоих эти значения будут одинаковые, а так не должно быть и у обоих и остальных, кто в будущем будет её вызывать результат пойдёт по одному месту

[Vindicar]

Herben, ну вообще это обычно делается через блокировку строк с помощью SELECT FOR UPDATE, но не все БД это умеют.
А вообще странно. Если ты просто прибавляешь единицу, то просто сделай соответствующий UPDATE, он должен быть атомарным (если, конечно, это не sqlite и ты не работаешь из разных потоков).