如何解决tokio :: spawn借入的值寿命不足-参数要求将'sleepy`借给'static'
此MWE显示tokio::spawn
循环中for in
的使用。带注释的代码sleepy_futures.push(sleepy.sleep_n(2));
可以正常工作,但不能运行/查询异步功能。
基本上,我想同时运行一堆异步函数。我很高兴更改Sleepy
的实现或使用其他库/技术。
pub struct Sleepy;
impl Sleepy {
pub async fn sleep_n(self: &Self,n: u64) -> String {
sleep(Duration::from_secs(n));
"test".to_string()
}
}
#[tokio::main(core_threads = 4)]
async fn main() {
let sleepy = Sleepy{};
let mut sleepy_futures = vec::Vec::new();
for _ in 0..5 {
// sleepy_futures.push(sleepy.sleep_n(2));
sleepy_futures.push(tokio::task::spawn(sleepy.sleep_n(2)));
}
let results = futures::future::join_all(sleepy_futures).await;
for result in results {
println!("{}",result.unwrap())
}
}
解决方法
在修复它方面有一个粗略的尝试:
use tokio::time::delay_for;
pub struct Sleepy;
impl Sleepy {
pub async fn sleep_n(n: u64) -> String {
delay_for(Duration::from_secs(n)).await;
"test".to_string()
}
}
现在不再将其固定在任何特定的Sleepy实例上,从而消除了生命周期问题。您会像Sleepy::sleep_n
这样称呼它。
如果需要&self
,则需要做更多的工作:
use std::sync::Arc;
use std::time::Duration;
use std::vec;
use tokio;
use tokio::time::delay_for;
pub struct Sleepy;
impl Sleepy {
pub async fn sleep_n(&self,n: u64) -> String {
// Call .await here to delay properly
delay_for(Duration::from_secs(n)).await;
"test".to_string()
}
}
#[tokio::main(core_threads = 4)]
async fn main() {
env_logger::init();
let sleepy = Arc::new(Sleepy {});
let mut sleepy_futures = vec::Vec::new();
for _ in 0..5 {
let sleepy = sleepy.clone();
// Dictate that values are moved into the task instead of
// being borrowed and dropped.
sleepy_futures.push(tokio::task::spawn(async move {
sleepy.sleep_n(2).await
}));
}
let results = futures::future::join_all(sleepy_futures).await;
for result in results {
println!("{}",result.unwrap())
}
}
这里Arc
用于包装对象,因为task
可能使用线程,因此Rc
不够。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。