AsyncReadExt::read_u64是否支持取消操作安全?
创始人
2024-09-21 08:30:25
0

AsyncReadExt::read_u64函数并不直接支持取消操作,但可以通过使用tokio::select!宏和一个额外的取消通道来实现取消。具体的实现方法如下:

use tokio::io::AsyncReadExt;
use tokio::sync::mpsc::{channel, Sender};
use std::io::Error;

async fn read_with_cancel(mut reader: R, cancel: Sender<()>) -> Result
where
    R: AsyncReadExt + Unpin,
{
    let mut buf = [0; 8];
    let mut n = 0usize;
    
    tokio::select! {
        res = reader.read(&mut buf) => {
            let mut bytes_read = res?;
            n += bytes_read;
            
            while bytes_read > 0 && n < 8 {
                bytes_read = reader.read(&mut buf[n..]).await?;
                n += bytes_read;
            }
        }
        _ = cancel.recv() => {
            return Err(Error::new(std::io::ErrorKind::Interrupted, "cancelled"));
        }
    }
    
    Ok(u64::from_be_bytes(buf))
}

这个函数将读取操作包含在了tokio::select!宏中,并在取消通道上等待。如果收到了一个取消请求,函数将立即返回带有一个Error的Result。否则,函数将连续尝试读取充分的字节数,之后将这些字节解析成一个u64值并返回。

相关内容

热门资讯

科普攻略!德普之星辅助器app... 科普攻略!德普之星辅助器app,we poker辅助器,德州论坛(有挂软件)是一款可以让一直输的玩家...
重大科普!佛手在线大菠萝智能辅... 重大科普!佛手在线大菠萝智能辅助器,wepoker作弊辅助,分享教程(有挂软件);原来确实真的有挂(...
一分钟教会你!wepoker怎... 一分钟教会你!wepoker怎么增加运气,epoker透视,切实教程(有挂透视)1、点击下载安装,微...
六分钟了解!hhpoker有辅... 六分钟了解!hhpoker有辅助吗,wepoker国外版透视,扑克教程(有挂技巧)科技教程也叫必备教...
我来教大家!wepoker辅助... 我来教大家!wepoker辅助透视,wepoker免费脚本弱密码,详细教程(有挂透明);wepoke...
记者发布!wpk辅助,德普之星... 记者发布!wpk辅助,德普之星透视辅助软件激活码,解密教程(有挂辅助);亲真的是有正版授权,小编(透...
揭秘攻略!aapoker万能辅... 《揭秘攻略!aapoker万能辅助器,hhpoker真的假的,揭秘教程(有挂教程)》 aapoker...
重大通报!sohoo poke... 自定义sohoo poker辅助器系统规律,只需要输入自己想要的开挂功能,一键便可以生成出微扑克专用...
三分钟了解!wpk辅助器,hh... 1、三分钟了解!wpk辅助器,hhpoker免费辅助器,必赢教程(有挂神器);详细教程。2、hhpo...
玩家必看攻略!wejoker私... 玩家必看攻略!wejoker私人辅助软件,智星德州可以透视吗,透明挂教程(有挂技巧)关于智星德州可以...