Телеграмм чат группы rust

Всем привет. В futures 0.1.x был метод futures_unordered, собиравщий вектор фьюч во фьючу с вектором. Пытаюсь сделать так-же в 0.3.5 - крейт перелопачен, растдок отсылает к функции collect в найтли билдах. Нет ли другого способа для стабильного раста?

источник

21:20пожаловаться #5

Ct

Casual tears in Rust Async

Danieλ Sλapman

Всем привет. В futures 0.1.x был метод futures_unordered, собиравщий вектор фьюч во фьючу с вектором. Пытаюсь сделать так-же в 0.3.5 - крейт перелопачен, растдок отсылает к функции collect в найтли билдах. Нет ли другого способа для стабильного раста?

https://docs.rs/futures/0.3.5/futures/stream/struct.FuturesUnordered.html
?

docs.rs

futures::stream::FuturesUnordered - Rust

API documentation for the Rust `FuturesUnordered` struct in crate `futures`.

источник

21:21пожаловаться #6

Ct

Casual tears in Rust Async

То что там линк на найтли доки не означает что оно не stable (:

источник

21:22пожаловаться #7

V

Vetro in Rust Async

https://docs.rs/futures/0.3.5/futures/stream/futures_unordered/struct.FuturesUnordered.html

docs.rs

futures::stream::futures_unordered::FuturesUnordered - Rust

API documentation for the Rust `FuturesUnordered` struct in crate `futures`.

источник

21:22пожаловаться #8

V

Vetro in Rust Async

Бл не успел

источник

21:22пожаловаться #9

V

Vetro in Rust Async

(((

источник

21:23пожаловаться #10

DS

Danieλ Sλapman in Rust Async

я конкретно про вот этот метод https://doc.rust-lang.org/nightly/core/iter/trait.Iterator.html#method.collect

doc.rust-lang.org

core::iter::Iterator - Rust

API documentation for the Rust `Iterator` trait in crate `core`.

источник

21:23пожаловаться #11

DS

Danieλ Sλapman in Rust Async

и правда, в стабильной версии есть https://doc.rust-lang.org/stable/core/iter/trait.Iterator.html#method.collect

doc.rust-lang.org

core::iter::Iterator - Rust

API documentation for the Rust `Iterator` trait in crate `core`.

источник

21:24пожаловаться #12

DS

Danieλ Sλapman in Rust Async

спасибо!

источник

21:24пожаловаться #13

DS

Danieλ Sλapman in Rust Async

А можно для FuturesUnordered указать тредпул, на котором эти фьючи выполять? Я вообще не очень понял, что происходит, вызов .collect::<FuturesUnordered<_>>().collect::<Vec<_>>() собрал мне сразу вектор, хотя я ожидал вектор внутри фьючи

источник

21:40пожаловаться #14

DS

Danieλ Sλapman in Rust Async

получается, это всё выполнится на текущем треде?

источник

21:40пожаловаться #15

V

Vetro in Rust Async

Danieλ Sλapman

А можно для FuturesUnordered указать тредпул, на котором эти фьючи выполять? Я вообще не очень понял, что происходит, вызов .collect::<FuturesUnordered<_>>().collect::<Vec<_>>() собрал мне сразу вектор, хотя я ожидал вектор внутри фьючи

На дефолтном тредпуле рантайма и выполнится

источник

21:41пожаловаться #16

DS

Danieλ Sλapman in Rust Async

окей, а насильно скормить другой тредпул нельзя?

источник

21:42пожаловаться #17

V

Vetro in Rust Async

Зачем?

источник

21:42пожаловаться #18

DS

Danieλ Sλapman in Rust Async

Чисто в образовательных целях 😅

источник

21:43пожаловаться #19

KK

Kirill (Cykooz) Kuzm... in Rust Async

Kirill (Cykooz) Kuzminykh

А это нормально, что tokio создаёт кучу тредов в actix-web (наверное по треду на каждый конект)? Мне казалось что в асинхронке как раз должно в основном всё работать в небольшом числе тредов. И то преимущественно треды должны использоваться для блокирующих операций.

Разобрался в чём проблема. Я в веб-серере на actix-web использую S3-клиент из крейта rusoto_s3. Он в свою очередь использует hyper. Последний по дефолту для резолва DNS использует стандартный, блокирующий резолвер. Вот он и порождал кучу тредов от tokio.
Я заюзал крейт hyper_trust_dns_connector с асинхронным DNS резолвером и все левые треды пропали.

Я изначально на DNS и подумал (в питоне такая же фигня по дефолту), но решил что поди в Rust сразу сделали нормальный асинхронный DNS резолвер.

источник

21:44пожаловаться #20