KS
Но через tokio::spawn он не работает в том смысле, что компилится, но сам прокси не запускается
Size: a a a
2021 May 27
IT
тебе надо proxy().await написать и убрать .await после tokio::spawn()
KS
Тогда компилер ругается и говорит что dyn std::error::Error can not be sent between threads safely
IT
ну где-то в другом месте же уже?
KS
Нет, в этом же самом.
KR
Box<dyn std::error::Error + Send> юзай
KS
Мне в принципе подходит решение выделить отдельный thread для этого, так как нет проблемы с производительностью. Только не могу нагуглить, как это сделать в async main-е. Нужно использовать Threadpool или у токио есть свои возможности это сделать?
IT
tokio::spawn() как раз и есть та возможность.
Просто async fn футуры ленивые и когда ты пишешь tokio::spawn(async move { proxy(); }) (при условии, что proxy - async fn), то собственно просто ничего не происходит, то есть создается футура, но она не выполняется.
Поэтому ее там надо .await, чтобы она стала выполняться
Ну и с + Send там правильное решение.
Просто async fn футуры ленивые и когда ты пишешь tokio::spawn(async move { proxy(); }) (при условии, что proxy - async fn), то собственно просто ничего не происходит, то есть создается футура, но она не выполняется.
Поэтому ее там надо .await, чтобы она стала выполняться
Ну и с + Send там правильное решение.
KS
Спасибо за объяснение. Вопрос, await я так понимаю ее poll-ит в ожидание ответа, но моя футура это по сути бесконечный loop, который ничего не врзвращает. Может быть в этом проблема?
П
Какую-то работу же она делает
П
А, Send Sync доку читать
IT
поллит, верно. В этом была бы проблема, если бы она запускалась .await в основной ветке кода, а tokio::spawn() создает отдельную таску для этой футуры и она должна бежать параллельно в этом случае.
IT
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=5e783307eca369763ec5b78f46756277
тут тоже бесконечный цикл, но он параллельно выполняется основному слипу
тут тоже бесконечный цикл, но он параллельно выполняется основному слипу
DF
все так, только 'конкуррертно' :)
DF
простите за буквоедстсво
KS
Хм, поставила в сигнатуре Result<(), Box<dyn std::error::Error + Send>>, все равно выдает ту же ошибку. Метод proxy не возвращает никакой Error.
KS
Это ведь работает в стэйбл расте или нужно помечать как анстейбл?
MB
Текст ошибки должен упоминать конкретное место в коде
KS
Сорри, все в том же месте, tokio::spawn
MB
По-моему там должна быть приписка типа
future is not Send because ...