作为一个非常简单的例子,我正在尝试编写一个简单回复的网络服务器
该页面已被请求 $N 次
但我在共享可变状态时遇到了很多麻烦。这是我最好的尝试:
extern crate hyper;
use hyper::Server;
use hyper::server::Request;
use hyper::server::Response;
struct World {
count: i64,
}
impl World {
fn greet(&mut self, req: Request, res: Response) {
self.count += 1;
let str: String = format!("this page has been requested {} times", self.count);
res.send(str.as_bytes()).unwrap();
}
}
fn main() {
println!("Started..");
let mut w = World { count: 0 };
Server::http("127.0.0.1:3001").unwrap()
.handle(move |req: Request, res: Response| w.greet(req, res) ).unwrap();
}
由于请求处理可能发生在不同的线程中,因此您需要同步对全局状态的访问,为此您需要使用诸如Mutex:
let w = Mutex::new(World { count: 0 });
Server::http("127.0.0.1:3001").unwrap()
.handle(move |req: Request, res: Response| w.lock().unwrap().greet(req, res))
.unwrap();
从签名中就可以看出这一点Server::handle():它要求其处理程序是Handler + 'static
, and Handler本身就需要Send + Sync
。因此,这个闭包捕获的所有内容也必须是'static + Send + Sync
,即可以安全地从多个线程访问。包装到互斥体中的值通常满足这些要求(当然,如果它们不包含引用)。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)