actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2025-02-02 09:39:03 +01:00
Code Issues Releases Wiki Activity

Encapsulate app state in Arc<Mutex<...>> (#54)

Browse Source
This commit is contained in:
Jan Niehusmann 2018-10-14 19:56:25 +02:00 committed by Douman
parent 0a2a356e7a
commit c6f092fc80
1 changed files with 6 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
state/src/main.rs
View File

@ -15,21 +15,22 @@ extern crate actix;
extern crate actix_web; extern crate actix_web;
extern crate env_logger; extern crate env_logger;
use std::cell::Cell; use std::sync::Arc;
use std::sync::Mutex;
use actix_web::{middleware, server, App, HttpRequest, HttpResponse}; use actix_web::{middleware, server, App, HttpRequest, HttpResponse};
/// Application state /// Application state
struct AppState { struct AppState {
counter: Cell<usize>, counter: Arc<Mutex<usize>>,
} }
/// simple handle /// simple handle
fn index(req: &HttpRequest<AppState>) -> HttpResponse { fn index(req: &HttpRequest<AppState>) -> HttpResponse {
println!("{:?}", req); println!("{:?}", req);
req.state().counter.set(req.state().counter.get() + 1); *(req.state().counter.lock().unwrap()) += 1;
HttpResponse::Ok().body(format!("Num of requests: {}", req.state().counter.get())) HttpResponse::Ok().body(format!("Num of requests: {}", req.state().counter.lock().unwrap()))
} }
fn main() { fn main() {
@ -38,7 +39,7 @@ fn main() {
let sys = actix::System::new("ws-example"); let sys = actix::System::new("ws-example");
server::new(|| { server::new(|| {
App::with_state(AppState{counter: Cell::new(0)}) // <- create app with state App::with_state(AppState{counter: Arc::new(Mutex::new(0))}) // <- create app with state
// enable logger // enable logger
.middleware(middleware::Logger::default()) .middleware(middleware::Logger::default())
// register simple handler, handle all methods // register simple handler, handle all methods