如何在tokio中实现与sync_channel(0)功能等价的会合通道？

标准库std::sync::mpsc在Tokio场景的可用性 #

可以正常使用，但需要遵循Tokio的调度规则：

• 仅在同步阻塞代码块或专用阻塞线程中直接调用std::sync::mpsc的发送/接收阻塞方法
• 若要在异步任务中使用，必须将阻塞调用包裹在tokio::task::spawn_blocking中提交执行，避免阻塞异步工作线程导致运行时调度卡顿，影响IO密集型场景的吞吐量

Tokio生态下的原生异步会合通道实现方案 #

Tokio官方的tokio::sync::mpsc不支持0容量的会合通道，传入0作为容量会直接触发panic，可选择以下替代方案：

• 方案1：用tokio::sync::oneshot模拟会合语义
  每次通信前创建新的oneshot通道，发送端await发送完成，接收端取走数据后自动通知发送端，天然满足会合要求，适合单次通信频繁的场景。
• 方案2：使用flume通道库
  flume同时支持同步/异步操作，直接调用flume::bounded(0)即可得到符合要求的会合通道，异步发送/接收方法可直接在Tokio异步任务中调用，无需额外适配，是目前落地成本最低的方案。
• 方案3：手动实现异步会合逻辑
  用tokio::sync::Mutex包裹Option<T>存储传输值，发送端加锁写入值后等待接收端读取并清空存储后再释放锁，即可实现异步场景下的会合效果。

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