我想轮询一个异步函数：
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
some_function().await;
}
我目前正在激活所有功能：
tokio = { version = "1.4.0", features = ["full"] }
其中哪些是必要的？
full = [
"fs",
"io-util",
"io-std",
"macros",
"net",
"parking_lot",
"process",
"rt",
"rt-multi-thread",
"signal",
"sync",
"time",
]
要使用 Tokio 对未来进行轮询，您需要一个Runtime.
这仅在 crate 功能上受支持
rt。
[dependencies]
tokio = { version = "1.4.0", features = ["rt"] }
fn main() -> Result<(), Box<dyn std::error::Error>> {
tokio::runtime::Builder::new_current_thread()
.build()
.unwrap()
.block_on(some_function())
}
async fn some_function() -> Result<(), Box<dyn std::error::Error>> {
Ok(())
}
如果要使用tokio::main宏：
这仅在 crate 功能上受
rt支持macros。
[dependencies]
tokio = { version = "1.4.0", features = ["rt", "macros"] }
#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
some_function().await
}
async fn some_function() -> Result<(), Box<dyn std::error::Error>> {
Ok(())
}
如果您想要您指定的确切语法（这不是“启用 Tokio 轮询未来的最小功能集”），那么运行时错误会指导您：
默认运行时风格是
multi_thread，但该rt-multi-thread功能已禁用。
[dependencies]
tokio = { version = "1.4.0", features = ["rt", "rt-multi-thread", "macros"] }
#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
some_function().await
}
async fn some_function() -> Result<(), Box<dyn std::error::Error>> {
Ok(())
}
也可以看看：