r
Программа сразу прекращает работу? Без вывода сообщений?
while let Some(task) = preloader_consumer.recv().await {внутри loop, сделал как вы прописали
let task = preloader_consumer.recv().await; и теперь все окSize: a a a
2020 March 13
MF
Вместо
внутри loop, сделал как вы прописали
внутри loop, сделал как вы прописали
r
Хм. С
while let тоже должно было работатьMF
red75prime а если мне нужно отправить ответ обратно конкретному продьюсеру, это нужно переходить на bounded и await?
r
Сделать чтобы продюсер создавал канал и добавить в task передающий конец канала.
r
Каналы однонаправленные
MF
red75prime
Сделать чтобы продюсер создавал канал и добавить в task передающий конец канала.
Т.е. нужно перед отправкой события, создать еще один локальный one-shot, например, и передать продьюсера уже глобальному консьюмеру?
r
В продюсере
let (tx, rx) = oneshot::channel(); task.tx = tx.clone(); send(task); let consumer_response = rx.await;MF
А мне же еще нужно отправить данные какие-то
MF
Т.е. просто в типе передавать tupple (data, oneshot_producer) ?
r
Да
MF
Спасибо, потихоньку начинаю понимать все это
MF
Правда еще появится проблема дальше, уже реализация логики внутри этого воркера. Вот ему приходят таски, но сама логика это по сути огромный синхронный кусок. получается мне нужно будет внутри консьюмера запускать поток и все равно синхронизировать через мьютексы какую-то структуру с тасками?
MF
Объясню чтобы понятней стало. Делаю пререндер SPA веб приложения, а логика это headless браузер, который с синхронным интерфейсом
MF
Но этот браузер может, например, в 5 вкладках подгружать таски/адреса параллельно
MF
Таски приходят, мне нужно их делать в очередь по 5 и отдавать через синхронный апи браузера ему задачи
MF
Правильно ли будет в асинхронном методе, где я жду таски продьюсером, создать новый thread полноценный и отдавать туда какую-то хешмапу, куда писать таски?
C
red75prime
std::thread::sleep в асинхронном коде не нужен никогда, от слова совсемСкажи это steam sdk
MF
red75prime
Ага, значит мне вместо thread::spawn в асинхронном нужно spawn_blocking, верно? А правильно ли будет создать структуру в мьютексе и шарить между тем, что внутри spawn_blocking и ее создателем?