文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

我们一起聊聊如何编写异步运行时通用库?

2024-11-29 23:16

关注

使用一个异步运行时,编写异步运行时通用库的好处是什么?

下面使用三种方法来实现异步运行时通用库。

方法1,定义自己的异步运行时Trait

使用futures crate,可以编写非常通用的库代码,但是time,sleep或timeout等操作必须依赖于异步运行时。这时,你可以定义自己的AsyncRuntime trait,并要求下游实现它。

use std::{future::Future, time::Duration};

pub trait AsyncRuntime: Send + Sync + 'static {
    type Delay: Future + Send;

    // 返回值必须是一个Future
    fn sleep(duration: Duration) -> Self::Delay;
}

可以像这样使用上面的库代码:

async fn operation() {
    R::sleep(Duration::from_millis(1)).await;
}

下面是它如何实现的:

pub struct TokioRuntime;

impl AsyncRuntime for TokioRuntime {
    type Delay = tokio::time::Sleep;

    fn sleep(duration: Duration) -> Self::Delay {
        tokio::time::sleep(duration)
    }
}

#[tokio::main]
async fn main() {
    operation::().await;
    println!("Hello, world!");
}

方法2,在内部抽象异步运行时并公开特性标志

为了处理网络连接或文件句柄,我们可以使用AsyncRead / AsyncWrite trait:

#[async_trait]
pub(crate) trait AsyncRuntime: Send + Sync + 'static {
    type Connection: AsyncRead + AsyncWrite + Send + Sync + 'static;

    async fn connect(addr: SocketAddr) -> std::io::Result;
}

可以像这样使用上面的库代码:

async fn operation(conn: &mut R::Connection) 
where
    R::Connection: Unpin,
{
    conn.write(b"some bytes").await;
}

然后为每个异步运行时定义一个模块:

#[cfg(feature = "runtime-async-std")]
mod async_std_impl;
#[cfg(feature = "runtime-async-std")]
use async_std_impl::*;

#[cfg(feature = "runtime-tokio")]
mod tokio_impl;
#[cfg(feature = "runtime-tokio")]
use tokio_impl::*;

tokio_impl模块:

mod tokio_impl {
    use std::net::SocketAddr;

    use async_trait::async_trait;
    use crate::AsyncRuntime;

    pub struct TokioRuntime;

    #[async_trait]
    impl AsyncRuntime for TokioRuntime {
        type Connection = tokio::net::TcpStream;

        async fn connect(addr: SocketAddr) -> std::io::Result {
            tokio::net::TcpStream::connect(addr).await
        }
    }
}

main函数代码:

#[tokio::main]
async fn main() {
    let mut conn =
        TokioRuntime::connect(SocketAddr::new(IpAddr::from_str("0.0.0.0").unwrap(), 8080))
            .await
            .unwrap();
    operation::(&mut conn).await;
    println!("Hello, world!");
}

方法3,维护一个异步运行时抽象库

基本上,将使用的所有异步运行时api写成一个包装器库。这样做可能很繁琐,但也有一个好处,即可以在一个地方为项目指定与异步运行时的所有交互,这对于调试或跟踪非常方便。

例如,我们定义异步运行时抽象库的名字为:common-async-runtime,它的异步任务处理代码如下:

// common-async-runtime/tokio_task.rs

pub use tokio::task::{JoinHandle as TaskHandle};

pub fn spawn_task(future: F) -> TaskHandle
where
    F: Future + Send + 'static,
    T: Send + 'static,
{
    tokio::task::spawn(future)
}

async-std的任务API与Tokio略有不同,这需要一些样板文件:

// common-async-runtime/async_std_task.rs

pub struct TaskHandle(async_std::task::JoinHandle);

pub fn spawn_task(future: F) -> TaskHandle
where
    F: Future + Send + 'static,
    T: Send + 'static,
{
    TaskHandle(async_std::task::spawn(future))
}

#[derive(Debug)]
pub struct JoinError;

impl std::error::Error for JoinError {}

impl Future for TaskHandle {
    type Output = Result;

    fn poll(
        mut self: std::pin::Pin<&mut Self>,
        cx: &mut std::task::Context<'_>,
    ) -> std::task::Poll {
        match self.0.poll_unpin(cx) {
            std::task::Poll::Ready(res) => std::task::Poll::Ready(Ok(res)),
            std::task::Poll::Pending => std::task::Poll::Pending,
        }
    }
}

在Cargo.toml中,你可以简单地将common-async-runtime作为依赖项包含进来。这使得你的库代码很“纯粹”,因为现在选择异步运行时是由下游控制的。与方法1类似,这个crate可以在没有任何异步运行时的情况下编译,这很简洁!

来源:coding到灯火阑珊内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯