RP
так-то async/await через генераторы работает уже сейчас)
Size: a a a
2021 January 07
F
они не будут работать параллельно, они будут работать "по очереди"
Ага, понял
RP
хотя если executor поддерживает многопоточность, они могут работать не только конкурентно, но и параллельно. опять таки зависит от того как часто ты используешь select/join/spawn
D
если во всём приложении нет ни единого спавна, то с многопоточностью не получится ))
RP
ну а в вырожденном случае с однотредовым экзекутором они будут работать только конкурентно и только при условии, что у тебя внутри есть select/join или аналоги
F
хотя если executor поддерживает многопоточность, они могут работать не только конкурентно, но и параллельно. опять таки зависит от того как часто ты используешь select/join/spawn
Ага, тоже сейчас всю эту разницу осознал
D
😁
F
ну а в вырожденном случае с однотредовым экзекутором они будут работать только конкурентно и только при условии, что у тебя внутри есть select/join или аналоги
А без select/join последовательно-не-конкуретно, несмотря на весь этот async/await, ок...
D
А без select/join последовательно-не-конкуретно, несмотря на весь этот async/await, ок...
поэтому обычно таки надо что-нибудь спавнить
RP
А без select/join последовательно-не-конкуретно, несмотря на весь этот async/await, ок...
если есть spawn, то конкурентно
2021 January 08
p
Всем ку. А есть ли какой-то аналог https://docs.rs/tokio-util/0.6.0/tokio_util/codec/trait.Decoder.html, который позволяет работать с невладеющими байтами, и который в свою очередь позволяет возвращать не
'static структуры?Там же нет констрейнта 'static на Item
p
Но всё ещё не понимаю, как async/await позволяет это сделать, если await приостанавливает выполнение текущей функции
Самый простой пример
let h1 = tokio::spawn(...);
let h2 = tokio::spawn(...);
h1.await;
h2.await;
let h1 = tokio::spawn(...);
let h2 = tokio::spawn(...);
h1.await;
h2.await;
2021 January 10
T
Привет! Ребята, что тут пошло не так? у меня же
Self::Module требует SyncT
T
MB
Привет! Ребята, что тут пошло не так? у меня же
Self::Module требует SyncТут рассматривается какая-то абстрактная dyn Future + Send. Вовсе не факт, что она Sync.
D
тебе нужно
Pin<Box<dyn Future + Sync>>, компилятор ведь прямо говорит )MB
тебе нужно
Pin<Box<dyn Future + Sync>>, компилятор ведь прямо говорит )dyn Future + Sync это плохой баунд
T
так а что мешает там Sync вывести?
D
ну, скорее всего понадобвится
dyn Future + Send :)