mirror of
https://github.com/actix/actix-website
synced 2025-02-08 22:36:07 +01:00
56 lines
1.2 KiB
Rust
56 lines
1.2 KiB
Rust
// <arc>
|
|
use actix_web::{get, web, App, HttpServer, Responder};
|
|
use std::{
|
|
cell::Cell,
|
|
sync::atomic::{AtomicUsize, Ordering},
|
|
sync::Arc,
|
|
};
|
|
|
|
#[derive(Clone)]
|
|
struct AppState {
|
|
local_count: Cell<usize>,
|
|
global_count: Arc<AtomicUsize>,
|
|
}
|
|
|
|
#[get("/")]
|
|
async fn show_count(data: web::Data<AppState>) -> impl Responder {
|
|
format!(
|
|
"global_count: {}\nlocal_count: {}",
|
|
data.global_count.load(Ordering::Relaxed),
|
|
data.local_count.get()
|
|
)
|
|
}
|
|
|
|
#[get("/add")]
|
|
async fn add_one(data: web::Data<AppState>) -> impl Responder {
|
|
data.global_count.fetch_add(1, Ordering::Relaxed);
|
|
|
|
let local_count = data.local_count.get();
|
|
data.local_count.set(local_count + 1);
|
|
|
|
format!(
|
|
"global_count: {}\nlocal_count: {}",
|
|
data.global_count.load(Ordering::Relaxed),
|
|
data.local_count.get()
|
|
)
|
|
}
|
|
|
|
#[actix_web::main]
|
|
async fn main() -> std::io::Result<()> {
|
|
let data = AppState {
|
|
local_count: Cell::new(0),
|
|
global_count: Arc::new(AtomicUsize::new(0)),
|
|
};
|
|
|
|
HttpServer::new(move || {
|
|
App::new()
|
|
.app_data(web::Data::new(data.clone()))
|
|
.service(show_count)
|
|
.service(add_one)
|
|
})
|
|
.bind(("127.0.0.1", 8080))?
|
|
.run()
|
|
.await
|
|
}
|
|
// </arc>
|