gpt4 book ai didi

rust - 为什么生成的 future 不由 tokio_core::reactor::Core 执行?

转载 作者:行者123 更新时间:2023-11-29 08:29:26 26 4
gpt4 key购买 nike

extern crate tokio; // 0.1.8

use tokio::prelude::*;

fn create_a_future(x: u8) -> Box<Future<Item = (), Error = ()>> {
Box::new(futures::future::ok(2).and_then(|a| {
println!("{}", a);
Ok(())
}))
}

fn main() {
let mut eloop = tokio_core::reactor::Core::new().unwrap();
let handle = eloop.handle();

for x in 0..10 {
let f = create_a_future(x);
handle.spawn(f);
}
}

我希望这会打印到标准输出,但它并没有发生。我是否以错误的方式使用了 spawn

最佳答案

正如评论中已经提到的,您正在设置一堆计算但从未运行任何计算。与迭代器一样,您可以将 futures 视为惰性。当您直接创建 future 但从未使用它时,编译器通常会告诉您这一点。在这里,您正在生成 future ,因此您不会收到警告,但没有任何东西会驱动 Tokio react 堆。

在许多情况下,您有一个特定的 future 想要运行,并且您将驱动 react 堆直到它完成。在其他情况下,您会“永远”运行 react 堆,无休止地处理新工作。

在这种情况下,您可以使用 Core::turn :

fn main() {
let mut eloop = tokio_core::reactor::Core::new().unwrap();
let handle = eloop.handle();

for x in 0..10 {
let f = create_a_future(x);
handle.spawn(f);
}

eloop.run(None);
}

eloop.turn(None);

-> Box<Future<Item = (), Error = ()>>

在现代 Rust 中,您不需要(而且可能不应该)这样做。最好返回匿名类型:

fn create_a_future() -> impl Future<Item = (), Error = ()> {
futures::future::ok(2).and_then(|a| {
println!("{}", a);
Ok(())
})
}
 tokio_core::reactor::Core

我的理解是,这个级别的 Tokio 是为更复杂的设置保留的。许多人可以只使用 tokio::runtokio::spawn:

fn main() {
tokio::run(futures::lazy(|| {
for _ in 0..10 {
tokio::spawn(create_a_future());
}
Ok(())
}))
}

关于rust - 为什么生成的 future 不由 tokio_core::reactor::Core 执行?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/53016728/

26 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com