r
Так сделать его футурой
Есть такой примитив синхронизации, как Tokio Notify, но чтобы он не расходовал permit при вызове
Notify::notified?Size: a a a
2021 February 02
IL
Привет!
Есть такой примитив синхронизации, как Tokio Notify, но чтобы он не расходовал permit при вызове
Есть такой примитив синхронизации, как Tokio Notify, но чтобы он не расходовал permit при вызове
Это, кстати, тот самый вопрос который я тут задавал
r
red75prime
Так сделать его футурой
async { loop { if flag { return something; } else { timer.await } } }
MB
Привет!
Есть такой примитив синхронизации, как Tokio Notify, но чтобы он не расходовал permit при вызове
Есть такой примитив синхронизации, как Tokio Notify, но чтобы он не расходовал permit при вызове
Notify::notified?Звучит как CancellationToken из tokio-util.
MB
Ну или аналог с каналами намутить
IL
Я пока ограничился чтением Notify в одном единственном месте, и OnceCell<()> в качестве индикатора
IL
Звучит как CancellationToken из tokio-util.
Если сделать cancel, а затем подписаться на cancelled(), то cancelled сразу сработает или залочится?
MB
Если сделать cancel, а затем подписаться на cancelled(), то cancelled сразу сработает или залочится?
Сработает сразу
IL
ок. спс
IL
Если бы ещё был такой же примитив, но который мог бы хранить внутри какое-нибудь значение, было бы вообще идеально )
MB
Я бы смотрел на tokio::sync::watch
MB
Можно хранить в нем Option<T> (изначально None, а потом Some(x) когда значение появилось)
IL
Ну а как это сделать на практике? Вот я хочу понять, когда попаду в специальное состояние. Я, например, читаю borrow(), он мне говорит что состояние пока не специальное(None), тогда я подписываюсь на changed. А пока подписывался - состояние перешло в специальное
IL
И у меня changed() в результате залочился навсегда
MB
let fut = rx.changed();
if rx.borrow().is_none() {
fut.await;
}
кажется вот так должно сработать
if rx.borrow().is_none() {
fut.await;
}
кажется вот так должно сработать
MB
А, хотя даже проще.
rx.borrow();
rx.changed().await;
тоже будет работать
rx.borrow();
rx.changed().await;
тоже будет работать
MB
Документация говорит, что .changed() отслеживает изменения не с начала своего исполнения, а с предыдущего вызова changed()
IL
Но она не говорит, относится ли это к данном инстансу ресивера, или ко всему каналу )
IL
Вообще, вотч по-моему может лагать, не?
IL
Хотя на самом деле, учитывая что меня инетерсует ровно один единственый переход, можно просто дропать сендер. Тогда changed() будет всегда выходить сразу