kbio是基于io_urig的异步IO框架,被用于实现 KuiBaDB 的异步I/O。
特性
支持多线程并发任务提交
速度快
实现在tokio中引入的AsycRead/AsycWritetrait
示例
asycfread_body(stream:&mutSock,cotet:&mutVec<u8>)->io::Result<()>{letle=stream.read_u32().await?;letmsgle=leasusize-size_of::<u32>();cotet.reserve(msgle);usafe{cotet.set_le(msgle);}stream.read_exact(cotet.as_mut_slice()).await?;returOk(());}
评论