Commit 88741be

committed

use arc mutex

1 parent 6bfeb47 commit 88741beCopy full SHA for 88741be

File tree

2 files changed

+16

-16

lines changed

src
- fetcher.rs
- main.rs

2 files changed

+16

-16

lines changed

`‎src/fetcher.rs`

Lines changed: 4 additions & 4 deletions

Original file line number	Diff line number	Diff line change
`@@ -175,7 +175,7 @@ pub struct Problems {`
`175`	`175`
`176`	`176`	`#[derive(Debug, Serialize, Deserialize)]`
`177`	`177`	`pub struct StatWithStatus {`
`178`		`- pubstat: Stat,`
	`178`	`+ stat: Stat,`
`179`	`179`	`difficulty: Difficulty,`
`180`	`180`	`paid_only: bool,`
`181`	`181`	`is_favor: bool,`
`@@ -184,19 +184,19 @@ pub struct StatWithStatus {`
`184`	`184`	`}`
`185`	`185`
`186`	`186`	`#[derive(Debug, Serialize, Deserialize)]`
`187`		`-pubstruct Stat {`
	`187`	`+struct Stat {`
`188`	`188`	`question_id: u32,`
`189`	`189`	`#[serde(rename = "question__article__slug")]`
`190`	`190`	`question_article_slug: Option<String>,`
`191`	`191`	`#[serde(rename = "question__title")]`
`192`	`192`	`question_title: Option<String>,`
`193`	`193`	`#[serde(rename = "question__title_slug")]`
`194`		`- pubquestion_title_slug: Option<String>,`
	`194`	`+ question_title_slug: Option<String>,`
`195`	`195`	`#[serde(rename = "question__hide")]`
`196`	`196`	`question_hide: bool,`
`197`	`197`	`total_acs: u32,`
`198`	`198`	`total_submitted: u32,`
`199`		`- pubfrontend_question_id: u32,`
	`199`	`+ frontend_question_id: u32,`
`200`	`200`	`is_new_question: bool,`
`201`	`201`	`}`
`202`	`202`

`‎src/main.rs`

Lines changed: 12 additions & 12 deletions

Original file line number	Diff line number	Diff line change
`@@ -19,6 +19,7 @@ use futures::executor::ThreadPool;`
`19`	`19`	`use futures::future::join_all;`
`20`	`20`	`use futures::stream::StreamExt;`
`21`	`21`	`use futures::task::SpawnExt;`
	`22`	`+use std::sync::{Arc, Mutex};`
`22`	`23`
`23`	`24`	`/// main() helps to generate the submission template .rs`
`24`	`25`	`fn main() {`
`@@ -63,18 +64,9 @@ fn main() {`
`63`	`64`	`let pool = ThreadPool::new().unwrap();`
`64`	`65`	`let mut tasks = vec![];`
`65`	`66`	`let problems = fetcher::get_problems().unwrap();`
`66`		`- let mut mod_file_addon = vec![];`
	`67`	`+ let mut mod_file_addon = Arc::new(Mutex::new(vec![]));`
`67`	`68`	`for problem_stat in problems.stat_status_pairs {`
`68`		`- mod_file_addon.push(format!(`
`69`		`- "mod p{:04}_{};",`
`70`		`- problem_stat.stat.frontend_question_id,`
`71`		`- problem_stat`
`72`		`- .stat`
`73`		`- .question_title_slug`
`74`		`- .clone()`
`75`		`- .unwrap()`
`76`		`- .replace("-", "_")`
`77`		`- ));`
	`69`	`+ let mod_file_addon = mod_file_addon.clone();`
`78`	`70`	`tasks.push(`
`79`	`71`	`pool.spawn_with_handle(async move {`
`80`	`72`	`let problem = fetcher::get_problem_async(problem_stat).await;`
`@@ -90,6 +82,14 @@ fn main() {`
`90`	`82`	`println!("Problem {} has no rust version.", problem.question_id);`
`91`	`83`	`return;`
`92`	`84`	`}`
	`85`	`+ async {`
	`86`	`+ mod_file_addon.lock().unwrap().push(format!(`
	`87`	`+ "mod p{:04}_{};",`
	`88`	`+ problem.question_id,`
	`89`	`+ problem.title_slug.replace("-", "_")`
	`90`	`+ ));`
	`91`	`+ }`
	`92`	`+ .await;`
`93`	`93`	`let code = code.unwrap();`
`94`	`94`	`async { deal_problem(&problem, &code, false) }.await`
`95`	`95`	`})`
`@@ -102,7 +102,7 @@ fn main() {`
`102`	`102`	`.append(true)`
`103`	`103`	`.open("./src/problem/mod.rs")`
`104`	`104`	`.unwrap();`
`105`		`- writeln!(lib_file, "{}", mod_file_addon.join("\n"));`
	`105`	`+ writeln!(lib_file, "{}", mod_file_addon.lock().unwrap().join("\n"));`
`106`	`106`	`break;`
`107`	`107`	`} else {`
`108`	`108`	`id = id_arg`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit 88741be

File tree

2 files changed

2 files changed

`‎src/fetcher.rs`

`‎src/main.rs`

0 commit comments