IB
По идее, LocalSet надо гонять на отдельном потоке, и потом пересылать в него футуры, которые надо выполнить (ну вернее штуки вида FnOnce() -> Future).
Идея LocalSet как раз в том, чтобы ничего не пересылать, ибо он для !Send.
Size: a a a
2021 March 22
MB
Идея LocalSet как раз в том, чтобы ничего не пересылать, ибо он для !Send.
В обычной таске !Send-футуру выполнить точно не получится
IB
В обычной таске !Send-футуру выполнить точно не получится
Поэтому LocalSet :)
MB
Поэтому LocalSet :)
LocalSet тоже !Send, поэтому запустить его в обычной таске тоже не выйдет
ph
а какие бывают кроме обычных?
MF
ага, spawn_local вместо run_until и где-то отдельно сделать await
MB
Ну еще бывают футуры, запущенные непосредственно в block_on, а также другие футуры, уже заспавненные в spawn_local.
D
Подскажите, я раньше делал
Но мне нужно там использовать библиотеку где тип не Send. Посоветовали взять LocalSet:
все работает компилится, но мне не нужно блокировать поток и делать await на run_until, а без этого оно не выполняется. spawn же запускал логику и не требует await
tokio::task::spawn(async move {Но мне нужно там использовать библиотеку где тип не Send. Посоветовали взять LocalSet:
local.run_until(async move {все работает компилится, но мне не нужно блокировать поток и делать await на run_until, а без этого оно не выполняется. spawn же запускал логику и не требует await
а тип который !Send я так понимаю используется сквозь вызовы await?
2021 March 23
К
Подскажите, я раньше делал
Но мне нужно там использовать библиотеку где тип не Send. Посоветовали взять LocalSet:
все работает компилится, но мне не нужно блокировать поток и делать await на run_until, а без этого оно не выполняется. spawn же запускал логику и не требует await
tokio::task::spawn(async move {Но мне нужно там использовать библиотеку где тип не Send. Посоветовали взять LocalSet:
local.run_until(async move {все работает компилится, но мне не нужно блокировать поток и делать await на run_until, а без этого оно не выполняется. spawn же запускал логику и не требует await
Быть может, использовать пометку blocking для блока кода? Ничто никуда пересылаться не будет, выполнение произойдёт в исходном потоке; но event loop из него будет перемещён в другой поток, так что асинхронный рантайм не заблокируется.
D
Быть может, использовать пометку blocking для блока кода? Ничто никуда пересылаться не будет, выполнение произойдёт в исходном потоке; но event loop из него будет перемещён в другой поток, так что асинхронный рантайм не заблокируется.
А как внутри блокинга футуры исполнять?
MB
Ну, можно block_on сделать :)
D
Тогда бы ему и локалсет подошёл
ph
https://docs.rs/tokio/1.4.0/tokio/task/struct.LocalSet.html#use-inside-tokiospawn
там оказывается рассматривается кейс прямо в доке
там оказывается рассматривается кейс прямо в доке
ph
у меня ложные воспоминания, или раньше локалсет можно было где угодно создавать?
2021 March 25
N
Привет всем!
N
Я заткнулся на проблеме, когда мне надо асинхронно раскидать куски работы из dashmap по фьючерсам и tokio:spawn, не могу доказать, что мапа переживает потоки. Собственно, строчка кода: https://github.com/NCrashed/bitcoin-utxo/blob/master/src/cache/utxo.rs#L217
N
У dashmap есть rayon итератор, но он не дружит с токио рантаймом напрямую :/
N
S
Arc?
N
Кэш живёт в Arc