如何解决同步/异步互操作通道
当您希望通过线程发送一系列事物(以线程阻塞的方式)时,例如crossbeam_channel
。
当您希望跨期货发送一系列事物时(以非线程阻塞,未来阻塞的方式),例如tokio::sync::mpsc
。
什么使我能够从阻塞线程发送并从异步上下文接收? (顺便说一句,我可以想象在某些时候需要相反的情况。)
我需要绑定通道,发送时阻塞线程,接收时阻塞未来。
我正在寻找某种性能,例如与crossbeam_channel
中所做的等同,但是唤醒未来而不是线程,并具有缓冲某些消息以避免尽可能多地阻塞的能力。对于多条消息场景,here给出的答案似乎有点像对此的修补。
解决方法
自从提出这个问题以来,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");
,
未来可以以阻塞的方式同步运行。您可以使用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,"testing");
使用此代码段,运行将来发送值将阻塞线程,直到将来完成为止,这类似于标准库通道的工作方式。如果需要,也可以在接收端使用它。
, crossfire
似乎是用来说明这一点的箱子。
ATM是最近才出现的,但并未得到广泛使用。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。