Всем привет, у меня вопрос. Использую actix. У меня есть асинхронный

Question

Всем привет, у меня вопрос. Использую actix. У меня есть асинхронный

сервер.
У меня есть состояние которое завернуто в Data<Arc<Mutex<State>>>
я завернул в не асинхронный мютекс состояние.
Есть роуты, один из них очень тяжелый, и там очень часто используется State,
я написал скрипт, который дает 100+ запросов за секунду по этому роуту,
и возникает проблема что запросы начинают обрабатываться, но это затягивается до вечности и если дать просто любой запрос на сервер, то он не обрабатывается а просто вечно грузится, может ли это быть из-за не асинхронного мютекса?
Я еще до конца не преисполнился в асинхронности и в мютексах и не совсем до конца понимаю из-за чего это, но подозреваю что это происходит из-за того что где-то в токио в планировщике задач параллельно блокируется мой State одновременно и из-за этого возникает проблема зависания. Поможет ли мне тут асинхронный мютекс? Или же мне использовать лучше сообщения? А может делить состояния на каждый запрос как это было показано в доках токио?

#backend #embedded #programming #russian #rust

0

14.07.2023

8 ответов

32 просмотра

Alexey Sokolovskiy

Удерживается ли lock guard мьютекса через какие-либо await? Например: let state = state.lock().unwrap(); smth.await; state.do_smth()

0

14.07.2023

Даня Автор вопроса

Alexey Sokolovskiy
Удерживается ли lock guard мьютекса через какие-ли...

да мой mutex используется в некоторых асинхрнных функциях если вы про это

0

14.07.2023

Alexey Sokolovskiy

Даня
да мой mutex используется в некоторых асинхрнных ф...

Важно не только в асинхронных функциях, а как именно Универсальный рецеп +- такой: Если мьютекс держится поверх какого-то из .await, то его надо делать асинхронным Если нет - не надо

0

14.07.2023

Angelicos Phosphoros

Вообще, если данные часто читаются, но редко изменяются, можно сделать так: Mutex<Arc<T>>, делать копию этого Arc под мьютексом и сразу освобождать его. Или, как вариант, использовать крейт arc-swap, который позволяет делать атомарный свап Arc. Если надо менять состояние, то можно сделать обновлённую копию, потом сделать std::mem::swap под блокировкой, освободить блокировку и дропнуть копию. Таким образом можно уменьшить критические секции. Ещё есть вариант разделить State на куски и каждый кусок защитить мьютексом, кусок выбирать через хэш каких-то входных данных запроса. Тогда 2 потока смогут одновременно работать, если у них хэши не совпадают. Асинхронный мьютекс поможет только другим запросам, которые вообще не используют эти данные.

0

14.07.2023

!van

Angelicos Phosphoros
Вообще, если данные часто читаются, но редко измен...

Если данные часто читаются, но редко меняются нужен RwLock

0

14.07.2023

Angelicos Phosphoros

!van
Если данные часто читаются, но редко меняются нуже...

С RwLock может случится, что будет writer starving (если у нас несправедливая реализация, например, в Linux). Вообще, зависит от ситуации. Если нам обязательно нужно новые данные возвращать, rwlock хорош, но в большинстве веб-сервисов eventual consistency приемлем. И в таких случаях есть смысл максимально сократить продолжительность критической секции.

0

14.07.2023

Даня Автор вопроса

Асинхронные мютексы и рвлоки помогли справится с этой проблемой

0

14.07.2023

!van · Accepted Answer

!van

состояние актора завернуто в мьютекс?

0

14.07.2023

172 похожих чатов

Всем привет, у меня вопрос. Использую actix. У меня есть асинхронный

8 ответов

Похожие вопросы