V
Чисто в образовательных целях 😅
Ну если cpu-bound то можешь в rayon запихнуть и результаты по каналу назад отправлять
Size: a a a
2020 August 26
DS
Vetro
Ну если cpu-bound то можешь в rayon запихнуть и результаты по каналу назад отправлять
Понял, спасибо
DS
rayon на вид похож на то, что я хочу получить
V
Понял, спасибо
Смотреть в сторону block_in_place и spawn_blocking
A
Vetro
На дефолтном тредпуле рантайма и выполнится
а как futures получит тредпул рантайма? я для выполнения в тредпуле токио пушил в FuturesUnordered
async { tokio::spawn(...).await }A
если мне не изменяет память, то без этого мой код выполнялся в одном потоке, выполняя футуры одну за другой
V
а как futures получит тредпул рантайма? я для выполнения в тредпуле токио пушил в FuturesUnordered
async { tokio::spawn(...).await }Ну я так полагаю что если он использует анордеред фьючи то он делает это уже в асинк функе с контекстом токио рантайма
V
Собственно на этом предположении все и держится))
2020 August 27
Ct
YM
спс
было tokio = { version = "0.2",
значит он брал не последнюю а какую-то 0.2.13 в которой нет stream_reader
было tokio = { version = "0.2",
значит он брал не последнюю а какую-то 0.2.13 в которой нет stream_reader
PP
спс
было tokio = { version = "0.2",
значит он брал не последнюю а какую-то 0.2.13 в которой нет stream_reader
было tokio = { version = "0.2",
значит он брал не последнюю а какую-то 0.2.13 в которой нет stream_reader
посмотри lock там должна быть зафиксированная версия
ph
cargo update -p tokio
YM
посмотри lock там должна быть зафиксированная версия
да так и есть
version = "0.2.13"
version = "0.2.13"
YM
cargo update -p tokio
спасибо
YM
как грамотно сделать обертку реализующую AsyncRead над
чтобы прервать чтение если суммарный размер прочитанного стал >N
?
Stream<Item = Result<impl Buf, Error>> чтобы прервать чтение если суммарный размер прочитанного стал >N
?
YM
конкретно мой кейс:
стрим отсюда https://docs.rs/warp/0.2.4/warp/filters/body/fn.stream.html
писать сюда https://docs.rs/tokio/0.2.22/tokio/fs/struct.File.html
через https://docs.rs/tokio/0.2.22/tokio/io/trait.AsyncWriteExt.html#method.write_buf
стрим отсюда https://docs.rs/warp/0.2.4/warp/filters/body/fn.stream.html
писать сюда https://docs.rs/tokio/0.2.22/tokio/fs/struct.File.html
через https://docs.rs/tokio/0.2.22/tokio/io/trait.AsyncWriteExt.html#method.write_buf
D
как грамотно сделать обертку реализующую AsyncRead над
чтобы прервать чтение если суммарный размер прочитанного стал >N
?
Stream<Item = Result<impl Buf, Error>> чтобы прервать чтение если суммарный размер прочитанного стал >N
?
D
Т.е. stream_reader + take