Э
Нет такого, насколько мне известно.
Size: a a a
2021 June 26
Э
Футуры могут кенсельнуться в самый неподходящий момент.
Э
Проще всего тупо не кенселить их.
n
Общая идея-то мне понятна (с прерыванием потока исполнения)
Пересмотрел пример и теперь не понимаю в чем там ошибка?
Вот код
Пересмотрел пример и теперь не понимаю в чем там ошибка?
Вот код
async fn parse_line(socket: &TcpStream) -> Result<String, Error> {
let len = socket.read_u32().await?; (1)
let mut line = vec![0; len];
socket.read_exact(&mut line).await?; (2)
let line = str::from_utf8(line)?;
Ok(line)
}
В (2) считается же тот Э
Это хардкорная фигня, тут проще всего прочитать про "panic safety". Кенселинг — это тот же самый panic safety, только в другой обёртке.
Но если ты хочешь объяснения, то у тебя
Но если ты хочешь объяснения, то у тебя
(1) вызывается два раза подряд из-за кенсела первой футуры, но твой код ожидает, что каждый вызов (1) будет в паре с вызовом (2).Э
Если бы у тебя футура не кенселилась никогда (или кенселилась только когда у тебя вся программа умирает), у тебя тут проблем бы не было.
n
Так .await? не вернёт разве ошибку? Т.е. тут больше graceful shutdown?
TK
Видимо, с какого-то перепугу авейт на 2 пендится, с размером принимаемых данных как-то связано раз. Мол, где-то ещё есть ссылка на сокет, которая читает из tcpstream. Так предположил.
Э
Ну и я не уверен, что понятно объяснил, потому что чтобы понять эту херню, надо знать про то, как выглядят футуры. Проще всего реально узнать про "panic safety", а потом предполагать, что в любом
await у тебя может эта херня запаниковать, а потом закетчиться (ну, собственно, кенсел футуры так примерно и делает).2021 June 27
Э
Нет, кенселинг футуры, говорю же. Хардкорная херня, надо знать как футуры работают, чтобы понять что именно тут не так, поэтому проще всего тупо не кенселить футуры.
Э
Нет, ты тоже не в ту сторону смотришь. У нас код выглядит как обычный растовый код, но на самом деле на любой
await надо смотреть как на херню, у которой внутри panic при кенселе вызывается, а на любой селект надо смотреть как на catch_unwind, который ловит эти паники после кенсела.TK
Так чему там паниковать-то? Или кенселить? Пример вроде простой.
Э
Ну то есть там на самом деле не паники, а кенсел, но я не знаю как это объяснить человеку, который не прочитал гигантскую статью про то, как на самом деле в расте устроены футуры.
Э
Просто прочитай "panic safety", там всё относительно просто написано про валидность стейта структур, а потом подумай про валидность
TpcStream, на который мы вызвали read_u32 два раза подряд.TK
Но почему он зовётся два раза подряд? Авейт же один.
Э
Ну то есть давай перепишем эту функцию на обычный растовый код из асинка:
fn parse_line(socket: &TcpStream, cancel_flag: Cell<bool>) -> Result<String, Error> {
let len = if cancel_flag.get() { panic!() } else { socket.read_u32()? }; // (1)
let mut line = vec![0; len];
if cancel_flag.get() { panic!() } else { socket.read_exact(&mut line)? }; // (2)
let line = str::from_utf8(line)?;
Ok(line)
}Э
А теперь поставь вместо селекта какую-нибудь конструкцию, которая ловит первый результат, ставит
cancel_flag.set(true) после того как поймает первый результат, а остальные ловит через catch_unwind.TK
Скетчили потом, а дальше что? Выполнение не продолжится с let mut line = ...?
Э
Ну то есть тут всё равно нет нормального примера, если не взять толстые треды, но просто представь, что мы так можем сделать.
Э
И скажи мне, что будет, если мы запаникуем на (2), не прочитав из стрима строку сначала?