捨棄 Future 表示 Future 無法再供輪詢。這稱為「取消」,可能發生在任何 await
時間點。即使 Future 遭到取消,也需審慎確保系統正常運作,例如不應出現死結或遺失資料。
XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX
Speaker Notes
-
編譯器無法確保安全的取消作業。您需要閱讀 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>> {
let raw = std::mem::take(&mut self.bytes);
let s = String::from_utf8(raw)
}
}
}
-
Interval::tick
會追蹤滴答是否「已送達」,因此可確保安全的取消作業。
-
AsyncReadExt::read
od.read) 只會傳回資料或不讀取資料,因此可確保安全的取消作業。
-
AsyncBufReadExt::read_line
與本範例相似,「無法」確保安全的取消作業。如要瞭解詳情和替代方案,請參閱說明文件。