Rust闭包与值生命周期问题：消息流测试报错求助

我是Rust初学者，正在实现消息流抽象的确认机制，其他部分进展顺利，但测试代码遇到生命周期错误。

测试逻辑是通过闭包监听消息投递确认、统计投递次数，但运行时报错：

`delivery_count` does not live long enough
borrowed value does not live long enough

可复现代码如下：

use std::cell::RefCell;
use std::rc::Rc;

struct QuasiStream<T> {
    delivery_listener: Option<Rc<RefCell<Box<dyn FnMut(&T)>>>>,
}
impl <T> QuasiStream<T> {
    pub fn new(delivery_listener: Option<Box<dyn FnMut(&T)>>) -> Self {
        QuasiStream {
            delivery_listener: match delivery_listener {
                Some(delivery_listener) => Some(Rc::new(RefCell::new(delivery_listener))),
                None => None,
            },
        }
    }
    pub fn publish(&self, item: T) {
        if let Some(delivery_listener) = &self.delivery_listener {
            delivery_listener.as_ref().borrow_mut()(&item);
        }
    }
}

#[test]
fn take_1() {
    let mut delivery_count = 0;
    let delivery_listener = |item: &i32| {
        delivery_count += 1;
    };

    let stream = QuasiStream::<i32>::new(Some(Box::new(delivery_listener)));
    for i in 0..10 {
        stream.publish(i);
    }
    assert_eq!(delivery_count, 10);
}

问题原因 #

原闭包捕获了delivery_count的可变引用，而未标注生命周期的Box<dyn FnMut(&T)>默认要求捕获变量满足'static生命周期。但delivery_count是栈上局部变量，生命周期仅覆盖到测试函数结束，而QuasiStream持有闭包的生命周期与自身一致，编译器判定delivery_count的生命周期不足以覆盖闭包的需求，因此报错。

你尝试过Rc<RefCell<i32>>但未成功，核心原因是没有让闭包捕获智能指针的所有权，仍然在捕获栈变量的引用。

解决方案 #

将统计变量包装在Rc<RefCell<i32>>中，通过move闭包捕获智能指针的克隆，让闭包拥有独立的指针所有权，从而满足生命周期要求。

修改后的完整代码：

use std::cell::RefCell;
use std::rc::Rc;

struct QuasiStream<T> {
    delivery_listener: Option<Rc<RefCell<Box<dyn FnMut(&T)>>>>,
}

impl<T> QuasiStream<T> {
    pub fn new(delivery_listener: Option<Box<dyn FnMut(&T)>>) -> Self {
        QuasiStream {
            delivery_listener: delivery_listener.map(|dl| Rc::new(RefCell::new(dl))),
        }
    }

    pub fn publish(&self, item: T) {
        if let Some(listener) = &self.delivery_listener {
            listener.borrow_mut()(&item);
        }
    }
}

#[test]
fn take_1() {
    // 用Rc<RefCell>包装统计变量，实现可变共享
    let counter = Rc::new(RefCell::new(0));
    // 克隆智能指针，供闭包捕获
    let counter_clone = Rc::clone(&counter);

    // move闭包获取counter_clone的所有权，避免捕获引用
    let delivery_listener = move |_item: &i32| {
        *counter_clone.borrow_mut() += 1;
    };

    let stream = QuasiStream::<i32>::new(Some(Box::new(delivery_listener)));
    for i in 0..10 {
        stream.publish(i);
    }

    assert_eq!(*counter.borrow(), 10);
}

关键说明 #

• Rc<RefCell<i32>>实现了可变共享：Rc允许多所有权，RefCell提供内部可变性，绕过Rust编译期可变规则。
• move关键字让闭包获取counter_clone的所有权，彻底避免捕获引用，满足'static生命周期要求。
• 测试结束时通过原counter获取最终统计值，验证结果。

内容的提问来源于stack exchange，提问作者zii