kbio是基于io_uring的异步IO框架,被用于实现 KuiBaDB 的异步I/O。
特性
支持多线程并发任务提交
速度快
实现在tokio中引入的AsyncRead/AsyncWritetrait
示例
asyncfnread_body(stream:&mutSock,content:&mutVec<u8>)->io::Result<()>{letlen=stream.read_u32().await?;letmsglen=lenasusize-size_of::<u32>();content.reserve(msglen);unsafe{content.set_len(msglen);}stream.read_exact(content.as_mut_slice()).await?;returnOk(());}
评论