gpt4 book ai didi

rust - 为什么在执行时未执行从Future::poll()调用的异步fn()?

转载 作者:行者123 更新时间:2023-12-03 11:42:25 24 4
gpt4 key购买 nike

我正在async fn()中调用Future::poll(),但是.await语句及其背后的代码在执行时未执行。

use futures::FutureExt;
use std::future::Future;
use std::pin::Pin;
use std::sync::{Arc, Mutex};
use std::task::{Context, Poll};

#[pin_project::pin_project]
struct Person<'a> {
name: &'a str,
age: i32,
}

impl<'a> Future for Person<'a> {
type Output = i32;

fn poll(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Self::Output> {
let mut this = self.project();
*this.age += 10;

let mut fut1 = fn1();
let pinfut1 = Pin::new(&mut fut1);
//let pinfut1 = unsafe { Pin::new_unchecked(&mut fut1) };
pinfut1.poll(cx)
}
}

fn fn1() -> impl Future<Output = i32> + Unpin {
async {
dbg!("sleep start!"); // execute here!
async_std::task::sleep(std::time::Duration::from_secs(5)).await; // <--- blocked here ?
dbg!("sleep done!"); // Never execute here!
123
}
.boxed()
}

fn main() {
let p1 = Person {
name: "jack",
age: Default::default(),
};
async_std::task::block_on(async {
let a = p1.await;
dbg!(a); // Never execute here!
});
std::thread::park();
}
playground
Cargo.toml:
[package]
name = "test-poll"
version = "0.1.0"
authors = ["xx <xx@xx.com>"]
edition = "2018"

# See more keys and their definitions at https://doc.rust-lang.org/cargo/reference/manifest.html

[dependencies]
async-std="1.8.0"
pin-project="0.4.6"
futures=""

最佳答案

每次轮询Person future时,您都会创建一个全新的fn1 future:

let mut fut1 = fn1();
该Future等待5秒,然后唤醒执行程序,该执行程序轮询 Person,然后创建一个全新的 fn1 future,等待5秒...
有关如何正确执行此操作的说明,请参见 How to implement a Future or Stream that polls an async fn?(尽管我同意您一开始可能不想执行此操作)。

关于rust - 为什么在执行时未执行从Future::poll()调用的异步fn()?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/65668865/

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