f
перед каждым start_send скидывается хук. Осталось понять, что такое хук 🙂
Size: a a a
2021 November 01
D
можно юзать из токио, там схема как описана в ишью, когда выдаётся пермит, что исключает возможность блокировки в случае прерывания футурки
f
пермит = гарантия свободного слота?
D
да
f
у меня нет проблемы с блоками. Я подозреваю проблему с liveness: навыдавали пермитов/гарантий слота, и встали.
D
ну, при дропе футуры он возвращается
f
как?
f
poll_ready возвращает просто unit, там вроде нет никакого способа сказать "disarm_ready", ишьюс как раз об этом
V
просто токийные каналы как раз и не юзают Sink/Stream)
D
ну посмотри код https://docs.rs/tokio/1.13.0/tokio/sync/mpsc/struct.Sender.html
там нет poll_ready и прочего интерфейса Sink'ов
там нет poll_ready и прочего интерфейса Sink'ов
f
ааа, этого я не знал
f
Понятно, permit-ы дропаются и всё хорошо
D
ну, как минимум в теории — это так :)
V
а flume как раз через хуки тоже реализует пермиты
f
Ну, а с futures::mpsc::Sender похоже проблема есть
V
и при этом может в Sink/Stream трейты
D
угу, похоже на то
f
Блин, это что ж получается... Вот есть у меня код
и он моментально убьет channel? 🤔
fn poll(self, cx: &mut ...) -> Poll {
loop {
if channel.poll_ready().is_ok() {
if let Some(msg) = queue.pop { channel.start_send(msg) }
}
}
}и он моментально убьет channel? 🤔
D
ну не моментально )
f
Я посмотрел на реализацию, ничего не резервируется