rust - 如何运行多个并行调用 thread::sleep 的 future ？

Question

<分区>

Answer 1

如果您将 futures 与 join() 相结合，它们将被转换为一个单个任务，在一个单个线程上运行。

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

但不幸的是，您实现的 future 不表现良好。它阻塞当前线程一秒钟，不允许在此期间完成任何其他工作。因为 future 在同一个线程上运行，所以它们不能同时运行。您的应用程序将休眠 2 秒。

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

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);
}

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