0

在下面的伪代码中,我使用了一个async使用 await 的 main 函数和一个使用 block_on 的非异步函数来调用异步函数。在这两种情况下,该过程都没有在那个阶段完成。如果可能,我想等待异步函数执行结束而不使用async


async fn asynchronous_ex_fn() -> Arc<Mutex<Vec<T>>> {
    let vec = Arc::new(Mutex::new(Vec::<T>::new()));
    // some .await
    vec
}

#[tokio::main]
async fn main() {
    let vec = asynchronous_ex_fn().await;
    let inner = Arc::try_unwrap(vec).try_inner().unwrap(); // Mutex<blocked
}

fn main() {
    let vec = tokio::runtime::Runtime::new().unwrap().block_on(asynchronous());
    let inner = Arc::try_unwrap(vec).unwrap().into_inner().unwrap();
    // not error but result is not completed ()
    // I was able to get the results of the task underway.
    // For example, if you perform a calculation 3000 times in a for loop 
    // and push the results to vec, only the results of about 300 times are pushed to vec.
}
4

1 回答 1

0

我不确定你的问题是什么,我假设let inner = Arc::try_unwrap(vec).unwrap().into_inner().unwrap();在异步函数调用中创建向量之前到达了这条线。

我刚刚在操场上复制了你的场景,它正在工作,看看这里

于 2021-04-25T15:29:06.907 回答