frost/bdk
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Create vector of thread handles to spawn threads

Browse Source 
Signed-off-by: nickfarrow <nick@nickfarrow.com>
This commit is contained in:
nickfarrow 2022-04-05 12:11:52 +10:00
parent 9c0141b5e3
commit adef166b22
No known key found for this signature in database
GPG Key ID: 992AF78384653A47
1 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/blockchain/esplora/ureq.rs
View File

@ -127,10 +127,11 @@ impl WalletSync for EsploraBlockchain {
.take(self.concurrency as usize) .take(self.concurrency as usize)
.cloned(); .cloned();
let handles = scripts.map(move |script| { let mut handles = vec![];
for script in scripts {
let client = self.url_client.clone(); let client = self.url_client.clone();
// make each request in its own thread. // make each request in its own thread.
std::thread::spawn(move || { handles.push(std::thread::spawn(move || {
let mut related_txs: Vec<Tx> = client._scripthash_txs(&script, None)?; let mut related_txs: Vec<Tx> = client._scripthash_txs(&script, None)?;
let n_confirmed = let n_confirmed =
@ -152,10 +153,11 @@ impl WalletSync for EsploraBlockchain {
} }
} }
Result::<_, Error>::Ok(related_txs) Result::<_, Error>::Ok(related_txs)
}) }));
}); }
let txs_per_script: Vec<Vec<Tx>> = handles let txs_per_script: Vec<Vec<Tx>> = handles
.into_iter()
.map(|handle| handle.join().unwrap()) .map(|handle| handle.join().unwrap())
.collect::<Result<_, _>>()?; .collect::<Result<_, _>>()?;
let mut satisfaction = vec![]; let mut satisfaction = vec![];