Скасування

Видалення ф’ючерсу означає, що він більше ніколи не може бути опитаний. Це називається скасуванням, і воно може відбутися в будь-який await момент. Потрібно бути обережним, щоб система працювала правильно, навіть якщо ф’ючерс скасовано. Наприклад, вона не повинна зайти в глухий кут або втратити дані.

XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX

Speaker Notes

 This slide should take about 18 minutes.

  • Компілятор не допомагає з безпекою скасування. Вам потрібно прочитати документацію до API і звернути увагу на те, який стан містить ваша async fn.

  • На відміну від panic і ?, скасування є частиною звичайного потоку керування (на відміну від обробки помилок).

  • Приклад втрачає частини рядка.

    • Щоразу, коли гілка tick() завершується першою, next() і його buf відкидаються.

    • LinesReader можна зробити безпечним для скасування, зробивши buf частиною структури:

      #![allow(unused)]
fn main() {
struct LinesReader {
    stream: DuplexStream,
    bytes: Vec<u8>,
    buf: [u8; 1],
}

impl LinesReader {
    fn new(stream: DuplexStream) -> Self {
        Self { stream, bytes: Vec::new(), buf: [0] }
    }
    async fn next(&mut self) -> io::Result<Option<String>> {
        // префікс buf та байти з self.
        // ...
        let raw = std::mem::take(&mut self.bytes);
        let s = String::from_utf8(raw)
            .map_err(|_| io::Error::new(io::ErrorKind::InvalidData, "не UTF-8"))?;
        // ...
    }
}
}

  • Interval::tick є безпечним для скасування, оскільки він відстежує, чи був тік ‘доставлений’.

  • AsyncReadExt::read є безпечним для скасування, оскільки він повертає або не читає дані.

  • AsyncBufReadExt::read_line схожий на приклад і не є безпечним для скасування. Подробиці та альтернативи дивится у його документації.