Как обрабатывать отправку и получение нескольких значений между двумя задачами?
Мне нужно отправлять и получать несколько значений между двумя задачами. В настоящее время я использую канал tokio oneshot, потому что занимаюсь только двумя задачами. Но я не могу повторно использовать tx, вероятно, из-за ограничения на одно сообщение. Как обычно решается эта ситуация?
- Я каждый раз создаю новый ваншот-канал? или есть способ повторно использовать канал?
- Попробовать ли я упаковать все свои взаимодействия в одно сообщение и сделать это только один раз? -> кажется очень ограничительным.
- Использую ли я другие типы каналов?
Почему Python в конце концов умрет
Последние 20 лет были действительно хорошими для Python. Он прошел путь от "просто языка сценариев" до основного языка, используемого для написания...
0
1
57
1
Перейти к ответу
Данный вопрос помечен как решенный
Ответы 1
Ответ принят как подходящий
В этой ситуации следует использовать канал tokio::sync::mpsc.
Я подозреваю, что вас беспокоит тот факт, что он поддерживает несколько отправителей, но вполне нормально использовать его, когда у вас есть только один отправитель.
да, я думаю, это то, о чем я беспокоился. Я попробую спасибо!
—
19.12.2022 06:55
Другие вопросы по теме
Собирать ошибки из горутин, вложенных в циклы
Nextflow: разделить или подмножить канал, содержащий кортежи
Флаттер | "runOnUiThread(object: Runnable() {public override fun run() {}})" Этот класс не имеет конструктора
Получить результат возврата во Flutter из Android (Kotlin) после вызова функции Android (Kotlin) из Flutter
Что не так с моим кодом Go Channel + Concurrency
Что делает оператор select только с предложением case (без выражения case) и case по умолчанию в Golang?
Как выполняется этот оператор выбора?
Не удалось получить данные модели в Django Async conusmers. работа в каналах и вебсокетах
GRPC: следует ли использовать один клиент для всего приложения?
Горутина, читающая из канала с динамическим циклом, получающим группу ожидания, повторно используется до того, как предыдущая была возвращена
Похожие вопросы
Имя метапрограммирования для функции и поиска типа в Rust?
Как я могу исправить свою ошибку «поток 'rocket-worker-thread' запаниковал при 'вызванном 'Option::unwrap()' со значением 'None', src\main.rs:25:44'?
`Результат в результате` с actix-web и mysql
Почему std::iter::Peekable::peek изменчиво заимствует аргумент self?
Выбор с индексированием является анти-шаблоном в Polars: как анализировать и преобразовывать (выбирать/фильтровать?) CSV, который, кажется, требует этого?
Проблема с проверкой пути и чтением файла в Rust
Как поддерживать двух посетителей, которые возвращают разные типы возвращаемых значений в Rust?
Реализовать методы для типажа без дополнительных признаков
Пул потоков Rust с кодом инициализации в каждом потоке?
Как мне написать код на Rust, который компилируется в сборку, похожую на ту, что создается GCC из C?
Почему вы используете одноразовый канал, если хотите отправить более одного сообщения? Судя по вашему расплывчатому описанию, вам, вероятно, нужен канал mpsc.