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

Я тут смотрю, как сделать Delay во Futures. В библиотеке futures-timer предложен вариант через вспомогательный thread делать.
А есть какие-либо способы во Futures сделать отложенный cx.waker().wake_by_ref(); в одном потоке?

источник

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

Mikail Bagishov in Rust Async

Магического отложенного wake нет.

В tokio все такие таймеры хранятся в одной очереди, и они одним потоком разгребаются (я не помню, отвечает ли этот поток за io и time одновременно или все-таки это два разных потока)

источник

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

Ilya Verpovsky in Rust Async

А если в run_executor использовать thread::park_timeout() с дополнительной логикой, вместо thread::park(); ?

источник

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

Сергей in Rust Async

Таймеры хранятся не совсем в очереди, и не в потоке, там специальная структура - binary heap, в которой периодически проверяется, не пора ли стрелять таймером

источник

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

Mikail Bagishov in Rust Async

Ну только не binary heap, a hash time wheel если я правильно помнб название

источник

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

Mikail Bagishov in Rust Async

Возможно, tokio нечто такое и делает. Но зачем заставлять каждый экзекутор это реализовывать - не очень понятно.

источник

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

pl 🦑 hk in Rust Async

Токио просто пихает ближайший таймаут в еполл

источник

10:25пожаловаться #20