同步/异步互操作通道答案

【问题标题】：Sync/async interoperable channels同步/异步互操作通道
【发布时间】：2021-03-14 23:26:16
【问题描述】：

当您希望跨线程（以线程阻塞方式）发送一系列事物时，您可以使用例如crossbeam_channel。当您希望跨期货发送一系列事物时（以非线程阻塞，未来阻塞的方式），您有例如tokio::sync::mpsc.

什么东西可以让我从阻塞线程发送，并从异步上下文接收？（顺便说一句，我可以想象在某些时候需要相反的情况。）

我需要限制通道，发送时线程阻塞，接收时阻塞未来。

我正在寻找一些高性能的东西，就像在crossbeam_channel 中所做的一样，但是唤醒未来而不是线程，能够缓冲一些消息以避免尽可能多的阻塞。对于多消息场景，here 给出的答案看起来有点像这方面的修补程序。

【问题讨论】：

标签： asynchronous rust synchronous

【解决方案1】：

自从提出这个问题以来，Tokio 提供的频道已经获得了执行此操作的功能。当您在非异步代码中时，您可以简单地调用通道上的blocking_send 和blocking_recv 方法：

let (mut tx, mut rx) = tokio::sync::mpsc::channel(10);

std::thread::spawn(move || {
    // send a value, blocking synchronously
    // this allows async channels to be used in non-async contexts
    tx.blocking_send("testing").unwrap();
});

// receive a value, blocking asynchronously
assert_eq!(rx.recv().await.unwrap(), "testing");

【讨论】：

【解决方案2】：

Futures 可以以阻塞方式同步运行。您可以使用futures::exector::block_on 来执行此操作，以允许在非异步上下文中发送：

let (mut tx, mut rx) = tokio::sync::mpsc::channel(10);

// send a value, blocking synchronously
// this allows async channels to be used in non-async contexts
futures::executor::block_on(tx.send("testing")).unwrap();

// receive a value, blocking asynchronously
assert_eq!(rx.recv().await.unwrap(), "testing");

使用这个 sn-p，运行 future 发送值将阻塞线程，直到 future 完成，类似于标准库通道的工作方式。如果需要，这也可以在接收端使用。

【讨论】：

【解决方案3】：

crossfire 似乎是专门为此而设计的板条箱。

ATM 是最近才出现的，但没有被广泛使用。

【讨论】：