b4tman/chgk_ledb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add async feature #1

Merged
b4tman merged 62 commits from async into master 2023-08-18 06:29:46 +00:00
Conversation 0 Commits 62 Files Changed 14 +4 -2
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 2c3950ccfc - Show all commits

6
app_async/src/main.rs
View File

@ -170,8 +170,10 @@ async fn read_from_db(id: u32) -> Option<Question> {
} }
async fn write_db() { async fn write_db() {
let (tx, rx) = mpsc::unbounded_channel::<Question>(); let (tx, rx) = mpsc::unbounded_channel::<Question>();
let (r, _) = tokio::join!(tokio::spawn(zip_reader_task(tx)), db_writer_task(rx),); tokio::try_join!(
r.expect("tokio join"); tokio::spawn(zip_reader_task(tx)),
tokio::spawn(db_writer_task(rx))
).expect("tokio join");
println!("all done"); println!("all done");
} }
async fn db_writer_task(rx: UnboundedReceiver<Question>) { async fn db_writer_task(rx: UnboundedReceiver<Question>) {