Добрый день господавры, приступил к изучению раста буквально пару дней

Question

Добрый день господавры, приступил к изучению раста буквально пару дней

назад и мне отчаянно нужна помощь.
Подскажите, пожалуйста, как мне решить проблему:
я открываю .write() на инстансе структуры (не шарю за терминологию) и пишу в его свойства. Но в других местах моей программы я должен читать из этого инстанса, (но тут есть момент - я должен держать write ОТКРЫТЫМ) но делать этого я не могу из-за :RwLock
что я должен делать в расте, чтобы читать и писать одновременно?

#backend #embedded #programming #russian #rust

0

28.03.2021

16 ответов

14 просмотров

Inspiration Catcher

Alex Noname
Ничо не понял. Зачем держать открытым. В любом слу...

Прошу прощения, однако в чем тогда цель этого чата?

0

28.03.2021

Ragnar Sigurðsson Автор вопроса

Alex Noname
Ничо не понял. Зачем держать открытым. В любом слу...

ок, спс

0

28.03.2021

Alex Noname

Ragnar Sigurðsson
ок, спс

Эээ... Все ещё не понял вопрос. Тут никто не пытается тебя послать. Не подумай так.

0

28.03.2021

Andrey Vlasov

Мб тебе подойдёт single producer-multi consumer channel?

0

28.03.2021

Inspiration Catcher

Выглядит как "я хочу отстрелить себе ногу, подскажите". Но вряд ли ты хотел спросить именно это. Возможно, тебе нужны lock-free структуры данных?

0

28.03.2021

Ragnar Sigurðsson Автор вопроса

Alex Noname
Эээ... Все ещё не понял вопрос. Тут никто не пытае...

Я так не думаю, я просто пошёл и спросил в этом соседнем чате :)

0

28.03.2021

Ragnar Sigurðsson Автор вопроса

Andrey Vlasov
Мб тебе подойдёт single producer-multi consumer ch...

его и юзаю я юзаю tokio и обертываю с помощью RwLock структуры, которые под капотом листенят вебсокеты и накапливают в себя данные. А другой таске мне надо читать и обрабатывать эти накопленные данные раз в секунду. Чтобы стартануть сами вебсокеты и начать запись, мне нужен write на RwLock В другом месте я читаю данные из этих структур, но т.к выхода из скоупа не произошло, данные структуры залочены и я не могу сделать их read. Основной вопрос: может использовать какой-то другой паттерн, чтобы обойти проблему или есть иные способы при текущей реализации? На расте недавно, я пытаюсь портировать node.js код

0

28.03.2021

Andrey Vlasov

Ragnar Sigurðsson
его и юзаю я юзаю tokio и обертываю с помощью RwLo...

Ты имплементируешь паттерн или юзаешь готовую реализацию?

0

28.03.2021

Ragnar Sigurðsson Автор вопроса

Andrey Vlasov
Ты имплементируешь паттерн или юзаешь готовую реал...

готовую реализацию, наверное. стандартную mpsc::channel. ну либо я не понял вопроса

0

28.03.2021

Andrey Vlasov

Ragnar Sigurðsson
готовую реализацию, наверное. стандартную mpsc::ch...

Тогда почему у тебя есть общий лок на чтение/запись?

0

29.03.2021

Ragnar Sigurðsson Автор вопроса

Andrey Vlasov
Тогда почему у тебя есть общий лок на чтение/запис...

потому что помимо отправки обработки данных в других тасках/потоках (для этого нужен лок), мне еще нужно обрабатывать события для других целей (отправлять конкретные кусочки данных, изменивших стейт залоченный)

0

29.03.2021

Andrey Vlasov

Ragnar Sigurðsson
потому что помимо отправки обработки данных в друг...

Для отправки лок не нужен, потому что в этом смысл канала. Трансмиттер для multi producer channel имплементирует Clone, поэтому его нужно клонировать, а не шерить. Лок у него есть внутри То же самое с принимающей стороной, если канал multi-consumer

0

29.03.2021

Αλεχ Zhukovsky

Раздели структуру на две

0

29.03.2021

Αλεχ Zhukovsky

Ragnar Sigurðsson
его и юзаю я юзаю tokio и обертываю с помощью RwLo...

У меня примерно такой же код к слову)

0

29.03.2021

Αλεχ Zhukovsky