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

00:06пожаловаться #1

Sergey in Rust Async

Подскажи пожалуйста по tokio Mutex
если мы лочим и берем значение:

let mut mutex_value: MutexGuard<String> = self.last_processed_block.lock().await

то такой спосоп установки нового значения:

*mutex_value = String::from("replaced");

и такой:

mem::replace(&mut *mutex_value, String::from("replaced"));

идентично работают? Или есть особенности? И какой будет использовать правильнее?

17:51пожаловаться #2

Kitsu in Rust Async

mem::replace возвращает замененное значение, так что компилятору придется выкинуть лишнее действие
а так, семантически эквивалентно, яб выбрал первый способ т.к. выглядит проще

17:54пожаловаться #3

Ivan Boldyrev in Rust Async

Идентично. Простое присваивание лучше, потому что не затуманивает происходящее.

17:54пожаловаться #4

Ivan Boldyrev in Rust Async

replace используется, если нужно старое значение, а в примерах этого нет.

17:55пожаловаться #5

Sergey in Rust Async

Спасибо

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

2021 November 25

у меня есть неизвестное количество футур которые я хочу запустить в одной таске и чтобы они исполнялись. что есть в токио для такого?

12:58пожаловаться #7

футуры постоянно добавляются в очередь

12:59пожаловаться #8

FuturesUnordered или просто spawn?

12:59пожаловаться #9

FuturesUnordered не могу найти

12:59пожаловаться #10

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

docs.rs

FuturesUnordered in futures::prelude::stream::futures_unordered - Rust

A set of futures which may complete in any order.

13:00пожаловаться #11

спасибо

13:01пожаловаться #12

так а они будут работать в фоне конкуретно с основным кодом или их эвейтить надо? мне так чтобы эвейтить было необязательно

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

Kitsu in Rust Async

Авейтить нужно, можешь заспавнить таску, где будет цикл с авейтами

13:06пожаловаться #14

Посмотри там в доке неплохо расписано.

Внутри FuturesUnordered они будут конкуррентно поллиться, но эвейтить нужно всю FuturesUnordered ток.

13:06пожаловаться #15

Let Eat Bee in Rust Async

может tokio::task::spawn_local подойдет?

15:48пожаловаться #16

Вероятно, если хочет в рамках одной таски, то чтобы дропались все вместе при случае.

15:50пожаловаться #17

Let Eat Bee in Rust Async

как раз подходит, spawn_local работает внутри LocalSet , который сам Future и его можно дропнуть

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

👍

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

Sergey in Rust Async

Есть ли возможность используя tokio_stream или futures использовать result внутри лямбды операции?
Например типа такого:
`tokio_stream::iter(collection)
.and_then(|value|-> async {value.try_into()})
.sum().await`