如何并行运行多个调用 thread::sleep 的期货?

Question

我有一个缓慢的未来，在运行完成之前会阻塞 1 秒。

我尝试使用join组合器，但复合未来my_app按顺序执行期货：

#![feature(pin, futures_api, arbitrary_self_types)]
extern crate futures; // v0.3
use futures::prelude::*;
use futures::task::Context;
use std::pin::PinMut;
use std::{thread, time};
use futures::executor::ThreadPoolBuilder;
struct SlowComputation {}
impl Future for SlowComputation {
type Output = ();
fn poll(self: PinMut<Self>, _cx: &mut Context) -> Poll<Self::Output> {
let millis = time::Duration::from_millis(1000);
thread::sleep(millis);
Poll::Ready(())
}
}
fn main() {
let fut1 = SlowComputation {};
let fut2 = SlowComputation {};
let my_app = fut1.join(fut2);
ThreadPoolBuilder::new()
.pool_size(5)
.create()
.expect("Failed to create threadpool")
.run(my_app);
}

为什么join会这样工作？我预计期货将在不同的线程上产生。

实现目标的正确方法是什么？

Cargo.toml：

[dependencies]
futures-preview = "0.3.0-alfa.6"

结果：

$ time target/debug/futures03
real    0m2.004s
user    0m0.000s
sys 0m0.004s

Answer 1

如果将 future 与join()结合起来，它们将被转换为单个任务，在单个线程上运行。

如果期货表现良好，它们将以事件驱动(异步(的方式并行运行。您希望应用程序休眠 1 秒钟。

但不幸的是，你实施的未来并不好。它会阻塞当前线程一秒钟，不允许在此期间执行任何其他工作。因为期货是在同一线程上运行的，所以它们不能同时运行。应用程序将休眠 2 秒钟。

请注意，如果您将示例更改为以下内容，则期货将保持单独的任务，您可以在线程池上独立并行运行它们：

fn main() {
let fut1 = SlowComputation {};
let fut2 = SlowComputation {};
let mut pool = ThreadPoolBuilder::new()
.pool_size(5)
.create()
.expect("Failed to create threadpool");
pool.spawn(fut1);
pool.run(fut2);
}

非常不鼓励编写阻塞主线程的期货，在实际应用程序中，您可能应该使用库提供的计时器，例如tokio::timer::Delay或tokio::timer::timeout::Timeout。