如何解決“Future不能安全地在線程之間發送”的問題？
作者：李明
當在Tokio運行的異步函數中使用Actix client時，可能會發生“error: future不能安全地在線程之間發送”的錯誤，這在使用Tokio和Actix庫時是一個常見的問題。今天，我們來看看如何解決這個問題。
Rust應用程序通常使用異步庫，如Tokio和Actix。這些庫為異步I/O和并行計算等提供了有力的支持。然而，不同的異步庫在一起使用時，有時會出現問題。
當在Tokio運行的異步函數中使用Actix client時，可能會發生“error: future不能安全地在線程之間發送”的錯誤，這在使用Tokio和Actix庫時是一個常見的問題。今天，我們來看看如何解決這個問題。
讓我們從一個簡單的代碼示例開始，它只適用于Actix，不會產生任何問題：
use actix_web::{web, App, HttpResponse, HttpServer};
use awc::Client;
#[actix_rt::main]
async fn main() {
actix_rt::spawn(async {
HttpServer::new(|| {
App::new()
.service(web::resource("/hello").route(web::get().to(ok)))
})
.bind("127.0.0.1:8080")?
.run()
.await
});
let client = Client::new();
let url = "http://127.0.0.1:8080/hello";
let ret = client.get(url).send().await.unwrap().body().await.unwrap();
println!("{:?}", ret);
}
async fn ok() -> HttpResponse {
HttpResponse::Ok()
.content_type("text/html; charset=utf-8")
.body("OK")
}在這段代碼中，我們使用Actix創建一個HTTP服務器，并使用Actix client向它發出GET請求。一切都很順利，但是當我們試圖在Tokio運行的異步函數中使用Actix client時，問題就開始了。
當我們嘗試在Tokio運行時中調用Actix client時，我們會遇到“error: future不能安全地在線程之間發送的錯誤。async block創建的future不是Send。類型 awc::Client 不是Send”。這是因為Actix client不是Send，這意味著它不能在線程之間安全地傳遞。
下面是導致此錯誤的示例代碼：
use actix_web::{web, App, HttpResponse, HttpServer};
use awc::Client;
#[actix_rt::main]
async fn main() {
actix_rt::spawn(async {
HttpServer::new(|| {
App::new()
.service(web::resource("/hello").route(web::get().to(ok)))
})
.bind("127.0.0.1:8080")?
.run()
.await
});
let r = tokio::spawn(async move {
let client = Client::new();
let url = "http://127.0.0.1:8080/hello";
client.get(url).send().await.unwrap().body().await.unwrap()
}).await.unwrap();
println!("{:?}", r);
}
async fn ok() -> HttpResponse {
HttpResponse::Ok()
.content_type("text/html; charset=utf-8")
.body("OK")
}為了解決這個問題并使代碼在Tokio中安全使用，我們可以使用來自Tokio的Oneshot機制。這種機制允許我們封裝Actix client的輸出，并在線程之間安全地傳遞它。
下面是用Oneshot用來解決這個問題的示例代碼：
use actix_web::{web, App, HttpResponse, HttpServer};
use awc::Client;
#[actix_rt::main]
async fn main() {
actix_rt::spawn(async {
HttpServer::new(|| {
App::new()
.service(web::resource("/hello").route(web::get().to(ok)))
})
.bind("127.0.0.1:8080")?
.run()
.await
});
let (sender, receiver) = tokio::sync::oneshot::channel();
actix_rt::spawn(async move {
let client = Client::new();
let url = "http://127.0.0.1:8080/hello";
let _ = sender.send(client.get(url).send().await.unwrap().body().await.unwrap());
});
let r = tokio::spawn(async move {
receiver.await.unwrap()
}).await.unwrap();
println!("{:?}", r);
std::mem::forget(runtime);
}
async fn ok() -> HttpResponse {
HttpResponse::Ok()
.content_type("text/html; charset=utf-8")
.body("OK")
}責任編輯：武曉燕
來源：
coding到燈火闌珊
