actix/examples
1
0
Fork 0
mirror of https://github.com/actix/examples synced 2024-11-23 22:41:07 +01:00
Code Issues Releases Wiki Activity

Merge pull request #114 from NathanielAJohnson/master

Browse Source 
clarify use of sleep in async_db
This commit is contained in:
Darin 2019-04-15 11:13:19 -04:00 committed by GitHub
commit 916c48367e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
async_db/src/db.rs
View File

@ -58,7 +58,7 @@ fn get_hottest_years(conn: Connection) -> Result<Vec<WeatherAgg>, Error> {
.collect::<Vec<WeatherAgg>>()) .collect::<Vec<WeatherAgg>>())
})?; })?;
sleep(Duration::from_secs(2)); sleep(Duration::from_secs(2)); //see comments at top of main.rs
Ok(annuals) Ok(annuals)
} }
@ -84,7 +84,7 @@ fn get_coldest_years(conn: Connection) -> Result<Vec<WeatherAgg>, Error> {
.collect::<Vec<WeatherAgg>>()) .collect::<Vec<WeatherAgg>>())
})?; })?;
sleep(Duration::from_secs(2)); sleep(Duration::from_secs(2)); //see comments at top of main.rs
Ok(annuals) Ok(annuals)
} }
@ -111,7 +111,7 @@ fn get_hottest_months(conn: Connection) -> Result<Vec<WeatherAgg>, Error> {
.collect::<Vec<WeatherAgg>>()) .collect::<Vec<WeatherAgg>>())
})?; })?;
sleep(Duration::from_secs(2)); sleep(Duration::from_secs(2)); //see comments at top of main.rs
Ok(annuals) Ok(annuals)
} }
@ -137,6 +137,6 @@ fn get_coldest_months(conn: Connection) -> Result<Vec<WeatherAgg>, Error> {
.collect::<Vec<WeatherAgg>>()) .collect::<Vec<WeatherAgg>>())
})?; })?;
sleep(Duration::from_secs(2)); sleep(Duration::from_secs(2)); //see comments at top of main.rs
Ok(annuals) Ok(annuals)
} }

2
async_db/src/main.rs
View File

@ -8,6 +8,8 @@ This project illustrates two examples:
2. An asynchronous handler that executes 4 queries in *parallel*, 2. An asynchronous handler that executes 4 queries in *parallel*,
collecting the results and returning them as a single serialized json object collecting the results and returning them as a single serialized json object
Note: The use of sleep(Duration::from_secs(2)); in db.rs is to make performance
improvement with parallelism more obvious.
*/ */
use std::io; use std::io;