2019-06-15 22:37:08 +02:00
|
|
|
// <arc>
|
2019-06-28 19:31:30 +02:00
|
|
|
use actix_web::{web, Responder};
|
2019-06-15 22:37:08 +02:00
|
|
|
use std::sync::atomic::{AtomicUsize, Ordering};
|
|
|
|
use std::sync::Arc;
|
|
|
|
|
2019-06-20 10:20:12 +02:00
|
|
|
#[derive(Clone)]
|
|
|
|
struct AppState {
|
|
|
|
count: Arc<AtomicUsize>,
|
|
|
|
}
|
|
|
|
|
2019-12-28 18:08:25 +01:00
|
|
|
async fn show_count(data: web::Data<AppState>) -> impl Responder {
|
2019-06-20 10:20:12 +02:00
|
|
|
format!("count: {}", data.count.load(Ordering::Relaxed))
|
|
|
|
}
|
2019-06-15 22:37:08 +02:00
|
|
|
|
2019-12-28 18:08:25 +01:00
|
|
|
async fn add_one(data: web::Data<AppState>) -> impl Responder {
|
2019-06-20 10:20:12 +02:00
|
|
|
data.count.fetch_add(1, Ordering::Relaxed);
|
2019-06-15 22:37:08 +02:00
|
|
|
|
2019-06-20 10:20:12 +02:00
|
|
|
format!("count: {}", data.count.load(Ordering::Relaxed))
|
2019-06-15 22:37:08 +02:00
|
|
|
}
|
|
|
|
|
2019-12-28 18:08:25 +01:00
|
|
|
#[actix_rt::main]
|
|
|
|
async fn main() -> std::io::Result<()> {
|
2019-06-28 19:31:30 +02:00
|
|
|
use actix_web::{App, HttpServer};
|
|
|
|
|
2019-06-20 10:20:12 +02:00
|
|
|
let data = AppState {
|
|
|
|
count: Arc::new(AtomicUsize::new(0)),
|
|
|
|
};
|
2019-06-15 22:37:08 +02:00
|
|
|
|
2019-06-20 10:20:12 +02:00
|
|
|
HttpServer::new(move || {
|
|
|
|
App::new()
|
2020-01-02 13:33:33 +01:00
|
|
|
.app_data(data.clone())
|
2019-06-20 10:20:12 +02:00
|
|
|
.route("/", web::to(show_count))
|
|
|
|
.route("/add", web::to(add_one))
|
2019-06-15 22:37:08 +02:00
|
|
|
})
|
2019-12-28 18:08:25 +01:00
|
|
|
.bind("127.0.0.1:8088")?
|
2019-06-20 10:20:12 +02:00
|
|
|
.run()
|
2019-12-28 18:08:25 +01:00
|
|
|
.await
|
2019-06-15 22:37:08 +02:00
|
|
|
}
|
|
|
|
// </arc>
|