MF
И подскажите, можно ли использовать синхронный RwLock в асинхронном коде, буквально записать в вектор данные
Size: a a a
2020 March 13
MF
Если брать асинхронный RwLock, я его не смогу использовать в синхронном обработчике логики
お
Господа, появился вопрос, может кто-то сталкивался с подобным?
Есть тип, который по сути обработчик (Fragment), принимающий что-то по ссылке и возвращающий что-то
Есть также структура, в которой хранится такой обработчик и имеющая метод, соединяющий обработчики
Проблема в том, что из-за ссылок в сигнатуре
И в методе
Как лучше реализовать подобное, если не менять сигнатуру
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=69e64141595249a5c356c342d602d95d
Есть тип, который по сути обработчик (Fragment), принимающий что-то по ссылке и возвращающий что-то
Есть также структура, в которой хранится такой обработчик и имеющая метод, соединяющий обработчики
Проблема в том, что из-за ссылок в сигнатуре
Fragment возникают проблемы с лайфтаймамиИ в методе
handler переменная не живёт достаточно долго для передачи в FragmentКак лучше реализовать подобное, если не менять сигнатуру
Fragment?https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=69e64141595249a5c356c342d602d95d
AS
И подскажите, можно ли использовать синхронный RwLock в асинхронном коде, буквально записать в вектор данные
нет
синхронный примитив заблокирует весь системный тред, а в этом же системном треде у тебя крутится весь event loop
синхронный примитив заблокирует весь системный тред, а в этом же системном треде у тебя крутится весь event loop
MF
А как тогда правильно сделать? Если мне нужно расшарить данные между асинхронным обработчиком тасков и синхронной обработкой этих тасков
AS
А как тогда правильно сделать? Если мне нужно расшарить данные между асинхронным обработчиком тасков и синхронной обработкой этих тасков
как там в го? коммуницируйте сообщениями, а не шарьте данные через память
AS
мне кажется лучше всего сделать так, чтобы синхронный обработчик посылал данные в канал, а асинхронный принимал эти данные и оперировал уже асинхронным локом
MF
Скажите, а Arc не работает внутри асинхронных функций?
MF
pub async fn loader_logic() {
let browser = create_browser(); // Arc<Browser>
loop {
if let Some(task) = preloader_consumer.recv().await { }
}
}MF
44 | let browser = create_browser();
| ------- has type `std::sync::Arc<Browser>`
...
48 | if let Some(task) = preloader_consumer.recv().await {
| ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^ await occurs here, with `browser` maybe used later
...
58 | }
| - `browser` is later dropped here
MF
Если убрать Arc, все ок компилируется
p
Откуда появился preloader_consumer?
r
Если брать асинхронный RwLock, я его не смогу использовать в синхронном обработчике логики
А зачем RwLock нужен? Создать отдельную задачу владеющую ресурсом, которая будет последовательно обрабатывать запросы.
MF
Вот проблема в том, что я хочу не последовательно, а пачками по 5
MF
и если сейчас 5 задач в обработке, ждать
r
Доступ к ресурсу, требующемуся для обработки, синхронный или асинхронный? Или там 5 разных ресурсов?
r
Если просто ограничивать количество задач, то можно добавить дополнительную задачу, которая будет раскидывать запросы на 5 задач-обработчиков.
В
Это же даже длиньше
зато не требует
PartialEq и можно игнорироват часть полейAT
Внимание! 😃
DK
1998