代码之家 › 专栏 › 技术社区 › attdona

如何并行运行多个调用thread::sleep的未来?[副本]

future rust

attdona · 技术社区 · 6 年前

我有一个缓慢的未来,在运行到完成前阻塞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);
}

参加 像那样工作?我期望未来会在不同的线程上产生。

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

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

结果:

$ time target/debug/futures03

real    0m2.004s
user    0m0.000s
sys 0m0.004s

1 回复 | 直到 5 年前

Shepmaster Tim Diekmann 6 年前

如果你把未来和 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

推荐文章

Kackao · 获取std::future的运行时间::wait\u for

6 年前

JRR · 出现错误时如何停止并行循环

6 年前

ozgeneral · 在R中使用异步未来追加全局表

6 年前

Joshua Esolk · 为什么在Akka Dispatcher上启动Futures时,Futures中的Futures会按顺序运行

6 年前

Mandroid · Java未来异步?

6 年前

opensourcegeek · 如何从流本身中取消无限流?

6 年前

Lingxi · 为什么没有std::future::try\u wait()?

6 年前

BorÈ Nicolae · 可调用类中的并发修改异常

7 年前

G.Saleh · scala Future运行顺序作业

7 年前

KOGI · 如何取消/中止Dart中的区域?

7 年前