multithreading - 产生线程并获得 future 结果的最佳方法是什么？

Question

这个问题在这里已经有了答案:





What is the best approach to encapsulate blocking I/O in future-rs?

(1 个回答)


2年前关闭。




有没有更好的方法来做类似下面的事情？

use futures::channel::oneshot; // 0.3.4
use std::thread;

pub async fn spawn<Y>(f: impl Fn() -> Y + Send + Sync + 'static) -> Y
where
    Y: Send + 'static,
{
    let (sender, receiver) = oneshot::channel::<Y>();
    thread::spawn(move || sender.send(f()));
    receiver.await.unwrap()
}

Answer 1

tokio::task::spawn_blocking是我一直在寻找的。