В рейтинге участвует:

групп:

каналов:

Виртуальный сервер на SSD - недорого!

Аренда выделенных и виртуальных серверов (VDS/VPS), хостинг, аренда IP-адресов, администрирование, круглосуточная поддержка

qwarta.ru подробнее

Резервное копирование с проверкой на вирусы!!!

Удобный сервис создания резервных копий на любой сервер сети интернет. Отслеживайте изменения, проверяйте на вирусы. Надежно защитите свой бизнес!

go.backupland.com

Выбираете сервер? Любая конфигурация на заказ!

Аренда физических серверов любых конфигураций под любые запросы - 1С бухгалтерия, игровые сервера, нагруженные проекты, интернет-магазины!

qwarta.ru подробнее

Size: a a a

Rust Async

472 membersпожаловаться на группу
2021 January 24

MB

Mikail Bagishov in Rust Async
antuan
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=66f5a9e893fcbf73b5acb6e3874e944e
вывод каждый раз разный:
0, 1, 2
2, 1, 0
0, 2, 1

чяднт?
play.rust-lang.org
Rust Playground
A browser interface to the Rust compiler to experiment with the language
А что не так?
источник
14:52пожаловаться#1

в🧇

вафель 🧇 in Rust Async
antuan
https://play.rust-lang.org/?version=stable&mode=debug&edition=2018&gist=66f5a9e893fcbf73b5acb6e3874e944e
вывод каждый раз разный:
0, 1, 2
2, 1, 0
0, 2, 1

чяднт?
play.rust-lang.org
Rust Playground
A browser interface to the Rust compiler to experiment with the language
https://docs.rs/tokio-stream/0.1.2/src/tokio_stream/stream_map.rs.html#493
docs.rs
stream_map.rs - source
Source of the Rust file `src/stream_map.rs`.
источник
14:53пожаловаться#2

в🧇

вафель 🧇 in Rust Async
вафель 🧇
https://docs.rs/tokio-stream/0.1.2/src/tokio_stream/stream_map.rs.html#493
docs.rs
stream_map.rs - source
Source of the Rust file `src/stream_map.rs`.
Т.е.: StreamMap начинает поллить со случайного стрима (thread_rng)
источник
14:54пожаловаться#3

DF

Dollar Føølish in Rust Async
StreamMap интересная штука, спасибо
источник
14:56пожаловаться#4

в🧇

вафель 🧇 in Rust Async
вафель 🧇
Т.е.: StreamMap начинает поллить со случайного стрима (thread_rng)
впрочем что странно, токио сам реализует свой thread_rng на основе xorshift64+ O_o
источник
14:57пожаловаться#5

a

antuan in Rust Async
вафель 🧇
Т.е.: StreamMap начинает поллить со случайного стрима (thread_rng)
И типа, пока первый выбранный не отдаст ответ - ко второму не перейдет? Не то, что я хотел. Так можно примерно с тем же успехом делать await у каждой таски по очереди.
источник
14:59пожаловаться#6

MB

Mikail Bagishov in Rust Async
Ну потому что скорость надо, а стойкость не надо.
источник
14:59пожаловаться#7

MB

Mikail Bagishov in Rust Async
antuan
И типа, пока первый выбранный не отдаст ответ - ко второму не перейдет? Не то, что я хотел. Так можно примерно с тем же успехом делать await у каждой таски по очереди.
Нет, поллит он все, пока не встретит готовый стрим.
источник
15:00пожаловаться#8

MB

Mikail Bagishov in Rust Async
Но начинает он с рандомной.
источник
15:00пожаловаться#9

MB

Mikail Bagishov in Rust Async
Видимо, разница между созданием этих трех ждущих футур оказывается очень мала по сравнению с разрешением таймера в токио.
источник
15:01пожаловаться#10

a

antuan in Rust Async
Тогда я бы предполагал, что таска со слипом в 0с будет готова первой, со слипом в 1с второй, в 2с - третьей
источник
15:01пожаловаться#11

в🧇

вафель 🧇 in Rust Async
antuan
Тогда я бы предполагал, что таска со слипом в 0с будет готова первой, со слипом в 1с второй, в 2с - третьей
у тебя все стримы изначально готовы и мгновенно возвращают фьючу (которую ты ждёшь потом)
источник
15:02пожаловаться#12

MB

Mikail Bagishov in Rust Async
А вот оно что :)
источник
15:02пожаловаться#13

a

antuan in Rust Async
вафель 🧇
у тебя все стримы изначально готовы и мгновенно возвращают фьючу (которую ты ждёшь потом)
А блет, и правда
источник
15:02пожаловаться#14

MB

Mikail Bagishov in Rust Async
Сорри, я неправильно понял код  :)
источник
15:03пожаловаться#15

a

antuan in Rust Async
вафель 🧇
у тебя все стримы изначально готовы и мгновенно возвращают фьючу (которую ты ждёшь потом)
А как быть? Без once не прокатит, ибо ждёт именно стрим в качестве значения
источник
15:03пожаловаться#16

в🧇

вафель 🧇 in Rust Async
antuan
А как быть? Без once не прокатит, ибо ждёт именно стрим в качестве значения
.and_then(identity)
источник
15:05пожаловаться#17

в🧇

вафель 🧇 in Rust Async
а нет стоп
источник
15:06пожаловаться#18

a

antuan in Rust Async
ага. мне нужен аналог select!, но для вектора.
источник
15:07пожаловаться#19

a

antuan in Rust Async
с удалением готовых тасок из вектора, желательно
источник
15:07пожаловаться#20