E
внутри spawn я вызываю tx.send(Ok(reply)).await
Size: a a a
2020 December 06
AI
Если нужно в текущем контексте иметь результат то только await, можно сразу на пачку
AI
внутри spawn я вызываю tx.send(Ok(reply)).await
"внутри spawn" значит что задача может выполняться даже не в текущем потоке. А значит поставив несколько задач в очередь они решатся в относительно рандомном порядке
E
tx.send(Ok(reply)).await из spawn убрать?
AI
Может тебе нужен условный join_all?
AI
А хотя это не по порядку
E
Может тебе нужен условный join_all?
мне нужно, чтобы за итерацию цикла завершился tx.send(Ok(reply)).await
AI
tx.send(Ok(reply)).await из spawn убрать?
Spawn выкидывает задачу на обработку в том числе и в соседние треды, так ты не получишь гарантий очередности
E
и чтобы за следующую итерацию запустился новый tx.send(Ok(reply)).await
AI
мне нужно, чтобы за итерацию цикла завершился tx.send(Ok(reply)).await
Тогда убери спавн и делай await в цикле
E
Тогда убери спавн и делай await в цикле
внутри цикла вызывать tx.send(Ok(reply)).await без spawn ?
AI
внутри цикла вызывать tx.send(Ok(reply)).await без spawn ?
Да. Ты же понимаешь для чего нужен spawn?
E
Да. Ты же понимаешь для чего нужен spawn?
в отдельном потоке запускать?
E
или в отдельной корутине?
AI
в отдельном потоке запускать?
Поставить задачу в общую очередь исполнения
AI
В текущем контексте без каких нибудь каналов ты от нее уже ничего не получишь если заспавнишь
AI
или в отдельной корутине?
Корутине скорее, хотя хз как это название к токио катит
E
я прямо внутри цикла tx.send(Ok(reply)).await вызывал, но на одной из итераций почему-то останавливалось
AI
Просто они сразу в нескольких потоках исполняются в дефолтном шедулере токио
AI
я прямо внутри цикла tx.send(Ok(reply)).await вызывал, но на одной из итераций почему-то останавливалось
Ну значит дебажь дальше )