You need to enable JavaScript to run this app.
最新活动
产品
解决方案
定价
生态与合作
支持与服务
开发者
了解我们

Rustfutures-使用Box::pin或pin_mut来在futures::select之外保持引用稳定性

在 Rust 中使用 futures 时,为了确保引用稳定性,可以使用 Box::pin 或 pin_mut 封装需要保持稳定的 future。但是,如果我们需要在 futures::select 宏之外使用封装后的 future,就会遇到引用稳定性问题。

为了解决这个问题,可以将封装后的 future 引用转换为不稳定的可变引用,然后在需要使用时重新封装为稳定的引用。

下面是一个示例代码:

use futures::future::FutureExt;
use futures::pin_mut;

async fn foo(input: String) -> String {
    // some async operations
    input
}

async fn bar(input: String) -> String {
    // some async operations
    input
}

#[tokio::main]
async fn main() {
    let mut fut1 = foo("hello".to_string()).boxed();
    let mut fut2 = bar("world".to_string()).boxed();

    pin_mut!(fut1, fut2);

    loop {
        futures::select_biased! {
            res1 = fut1 => {
                let input = res1.unwrap();
                fut1.as_mut().set(foo(input)).unwrap();
                println!("fut1 finished with {}", input);
            }
            res2 = fut2 => {
                let input = res2.unwrap();
                fut2.as_mut().set(bar(input)).unwrap();
                println!("fut2 finished with {}", input);
            }
            complete => break,
        }
    }
}

在这个示例中,我们使用了 futures::select_biased 宏来轮流执行两个 future fut1 和 fut2 的逻辑。通过使用 pin_mut! 宏来转换可变引用到 Boxed Future,我们可以保持引用的稳定性。

在 select 宏执行每个 future 之前,我们使用 as_mut() 函数将 future 的引用转换为可变引用,并在执行完成后重新封装为稳定的 Boxed Future 对象。

这种方式可以确保 future 的引用在不同的执行过程中保持稳定,同时又不会影响 select 宏的正确执行。

本文内容通过AI工具匹配关键字智能整合而成,仅供参考,火山引擎不对内容的真实、准确或完整作任何形式的承诺。如有任何问题或意见,您可以通过联系service@volcengine.com进行反馈,火山引擎收到您的反馈后将及时答复和处理。
展开更多
面向开发者的云福利中心,ECS 60元/年,域名1元起,助力开发者快速在云上构建可靠应用

社区干货

节省90%编译时间,这是字节跳动开源的基于Rust的前端构建工具

Rspack 是一个基于 Rust 的高性能构建引擎,它可以与 Webpack 生态系统交互,并提供更好的构建性能。在处理具有复杂构建配置的巨石应用时,Rspack 可以提供 5~10 倍的编译性能提升。字节跳动将 Rspack 开源后,它... (这里不是说rust 是完美的,只是在当前场景下没有前两种选型的问题)。 1. Rust 性能很好,和 C/CPP 一个级别。2. napi 支持良好,降低了我们在兼容 webpack 复杂 API 时的心智负担,除此之外,因为有宏的支...

字节开源 Monoio :基于 io-uring 的高性能 Rust Runtime

另外也容易在 callback 依赖的变量的生命周期上踩坑,比如在 callback 执行前提前释放了它会引用的变量。但在 Rust 中只需要创建两个 task 并等待 task 执行结束即可。![picture.image](https://p3-volc-comm... { let this = self.get mut( ); loop { match this { SumFuture::FirstDoHTTP(f) => { let pinned = unsafe { Pin::new\_unchecked(f...

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

Rustfutures-使用Box::pin或pin_mut来在futures::select之外保持引用稳定性 -优选内容

节省90%编译时间,这是字节跳动开源的基于Rust的前端构建工具
Rspack 是一个基于 Rust 的高性能构建引擎,它可以与 Webpack 生态系统交互,并提供更好的构建性能。在处理具有复杂构建配置的巨石应用时,Rspack 可以提供 5~10 倍的编译性能提升。字节跳动将 Rspack 开源后,它... (这里不是说rust 是完美的,只是在当前场景下没有前两种选型的问题)。 1. Rust 性能很好,和 C/CPP 一个级别。2. napi 支持良好,降低了我们在兼容 webpack 复杂 API 时的心智负担,除此之外,因为有宏的支...
字节开源 Monoio :基于 io-uring 的高性能 Rust Runtime
另外也容易在 callback 依赖的变量的生命周期上踩坑,比如在 callback 执行前提前释放了它会引用的变量。但在 Rust 中只需要创建两个 task 并等待 task 执行结束即可。![picture.image](https://p3-volc-comm... { let this = self.get mut( ); loop { match this { SumFuture::FirstDoHTTP(f) => { let pinned = unsafe { Pin::new\_unchecked(f...

Rustfutures-使用Box::pin或pin_mut来在futures::select之外保持引用稳定性 -相关内容

特惠活动

热门爆款云服务器

100%性能独享,更高内存性能更佳,学习测试、web前端、企业应用首选,每日花费低至0.55元
60.00/1212.00/年
立即购买

域名注册服务

cn/top/com等热门域名,首年低至1元,邮箱建站必选
1.00/首年起32.00/首年起
立即购买

DCDN国内流量包100G

同时抵扣CDN与DCDN两种流量消耗,加速分发更实惠
2.00/20.00/年
立即购买

产品体验

体验中心

云服务器特惠

云服务器
云服务器ECS新人特惠
立即抢购

白皮书

一图详解大模型
浓缩大模型架构,厘清生产和应用链路关系
立即获取

最新活动

爆款1核2G共享型服务器

首年60元,每月仅需5元,限量秒杀
立即抢购

火山引擎增长体验专区

丰富能力激励企业快速增长
查看详情

数据智能VeDI

易用的高性能大数据产品家族
了解详情

一键开启云上增长新空间

立即咨询