Mirror/brk
1
0
Fork 0
mirror of https://github.com/bitcoinresearchkit/brk.git synced 2026-07-31 20:53:06 -07:00
Code Issues Packages Projects Releases Wiki Activity

computer: reduce even more the number of par threads for compute_rest_part2

Browse Source
This commit is contained in:
nym21
2025-07-09 12:32:50 +02:00
parent 617d6f4bd7
commit 811dec713b
2 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
crates/brk_computer/src/stores.rs
-1
View File
@@ -598,7 +598,6 @@ impl Stores {
} }
pub fn rotate_memtables(&self) { pub fn rotate_memtables(&self) {
info!("Rotatin memtables...");
self.as_slice() self.as_slice()
.into_iter() .into_iter()
.for_each(|store| store.rotate_memtable()); .for_each(|store| store.rotate_memtable());
crates/brk_computer/src/vecs/stateful/mod.rs
+1 -2
View File
@@ -1301,7 +1301,7 @@ impl Vecs {
.collect::<Vec<Either<&mut utxo_cohort::Vecs, &mut address_cohort::Vecs>>>(); .collect::<Vec<Either<&mut utxo_cohort::Vecs, &mut address_cohort::Vecs>>>();
// Capped as external drives (even thunderbolt 4 SSDs) can be overwhelmed // Capped as external drives (even thunderbolt 4 SSDs) can be overwhelmed
let chunk_size = (vecs.len() as f64 / 4.0).ceil() as usize; let chunk_size = (vecs.len() as f64 / 3.0).ceil() as usize;
vecs.into_par_iter().chunks(chunk_size).try_for_each(|v| { vecs.into_par_iter().chunks(chunk_size).try_for_each(|v| {
v.into_iter().try_for_each(|either| match either { v.into_iter().try_for_each(|either| match either {
Either::Left(v) => v.compute_rest_part2( Either::Left(v) => v.compute_rest_part2(
@@ -1331,7 +1331,6 @@ impl Vecs {
}) })
})?; })?;
info!("Computing rest part 2 (others)...");
self.indexes_to_unspendable_supply.compute_rest( self.indexes_to_unspendable_supply.compute_rest(
indexer, indexer,
indexes, indexes,