单任务双Future场景下：Atomic与Cell计数器选型咨询

你的核心理解完全正确：同一任务（task）内的多个Future永远不会被执行器并发调度——哪怕是多线程执行器，同一个task的所有Future执行步骤都是串行推进的，不存在同时读写计数器的竞态条件。基于这个前提，Cell是完全安全且性能最优的选择，理由如下：

1. Cell的性能优势 #

Cell是Rust为单线程场景设计的可变容器，其读写操作都是直接的内存访问，无任何同步开销：

• 读取是直接加载内存值，不需要内存屏障或总线锁
• 写入是直接存储内存值，同样没有额外的原子指令成本

而原子类型（如AtomicUsize）本质是为跨线程并发读写设计的，哪怕使用最宽松的Relaxed内存顺序，也会引入原子指令的额外开销——在多核场景下，这种不必要的同步会直接拉低性能，完全是资源浪费。

2. 安全性验证 #

只要你的两个Future属于同一个task（比如通过tokio::select!、futures::join!组合，或者在同一个async块内交替执行），就不存在并发访问计数器的可能：

• 数据处理Future只会在recv()返回后才会修改计数器
• 统计请求Future只会在recv()返回后才会读取计数器
• 执行器会保证同一task内的这些步骤不会被拆分到多个线程并行执行，读写操作完全错开

示例代码 #

use std::cell::Cell;
use tokio::sync::{mpsc, oneshot};

struct TaskWorker {
    processed_count: Cell<usize>,
}

impl TaskWorker {
    fn new() -> Self {
        Self { processed_count: Cell::new(0) }
    }

    // 数据处理Future：消费输入、转换发送、递增计数器
    async fn process_data(&self, mut input_rx: mpsc::Receiver<u32>, output_tx: mpsc::Sender<u64>) {
        while let Some(raw) = input_rx.recv().await {
            let transformed = raw as u64 * 2;
            output_tx.send(transformed).await.expect("输出通道已关闭");
            // 直接修改Cell，无同步开销
            self.processed_count.set(self.processed_count.get() + 1);
        }
    }

    // 统计请求处理Future：响应计数器值
    async fn handle_stats_req(&self, mut req_rx: mpsc::Receiver<oneshot::Sender<usize>>) {
        while let Some(resp_tx) = req_rx.recv().await {
            let current_count = self.processed_count.get();
            resp_tx.send(current_count).expect("响应通道已关闭");
        }
    }

    // 启动同一任务内的两个Future
    async fn run(self) {
        let (_input_tx, input_rx) = mpsc::channel(100);
        let (_output_tx, _output_rx) = mpsc::channel(100);
        let (_req_tx, req_rx) = mpsc::channel(10);

        // 同一任务内交替执行两个Future，无并发风险
        tokio::select! {
            _ = self.process_data(input_rx, _output_tx) => {},
            _ = self.handle_stats_req(req_rx) => {},
        }
    }
}

例外情况 #

如果后续你需要将两个Future拆分到不同的task中（比如分别调用tokio::spawn），那才需要替换为原子类型。但在当前的任务内共享场景下，Cell是绝对的最优解。

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