Benchmark with multiple threads

Author: Eunovo

src/bench/wallet_silentpayments_scan.cpp

@@ -13,6 +13,7 @@
 #include <script/sign.h>
 #include <script/signingprovider.h>
 #include <sync.h>
+#include <util/threadpool.h>
 #include <validation.h>
 #include <wallet/test/util.h>
 #include <wallet/receive.h>
@@ -26,7 +27,7 @@ static int SATS_PER_OUTPUT = 1;
 static int FEE_SATS = 1000;
 static size_t SP_RECIPIENT_GROUP_LIMIT = 1000;
 
-static void WalletSPScan(benchmark::Bench& bench, size_t num_txs, size_t outputs_per_tx)
+static void WalletSPScan(benchmark::Bench& bench, size_t num_txs, size_t outputs_per_tx, size_t n_workers = 1)
 {
     auto testsetup = TestChain100Setup();
     auto& m_node = testsetup.m_node;
@@ -67,7 +68,9 @@ static void WalletSPScan(benchmark::Bench& bench, size_t num_txs, size_t outputs
     CBlockIndex* currentTip = WITH_LOCK(Assert(m_node.chainman)->GetMutex(), return m_node.chainman->ActiveChain().Tip());
     assert(nHeight == currentTip->nHeight);
 
-    CWallet wallet(m_node.chain.get(), "", CreateMockableWalletDatabase());
+    ThreadPool threadpool{"spbench"};
+    CWallet wallet{m_node.chain.get(), "", CreateMockableWalletDatabase(), &threadpool};
+    if (n_workers > 1) threadpool.Start(n_workers - 1);
     {
         LOCK(wallet.cs_wallet);
         LOCK(Assert(m_node.chainman)->GetMutex());
@@ -147,8 +150,20 @@ static void WalletSPScan(benchmark::Bench& bench, size_t num_txs, size_t outputs
  */
 static void WalletSPScanMaxTxOneOutput(benchmark::Bench& bench) { WalletSPScan(bench, 8986, 1); }
 static void WalletSPScanOneTxMaxOutputs(benchmark::Bench& bench) { WalletSPScan(bench, 1, 23246); }
+static void WalletSPScanOneTxMaxOutputs2(benchmark::Bench& bench) { WalletSPScan(bench, 1, 23246, 2); }
+static void WalletSPScanOneTxMaxOutputs4(benchmark::Bench& bench) { WalletSPScan(bench, 1, 23246, 4); }
+static void WalletSPScanOneTxMaxOutputs8(benchmark::Bench& bench) { WalletSPScan(bench, 1, 23246, 8); }
 static void WalletSPScanAvgTxAvgOutputs(benchmark::Bench& bench) { WalletSPScan(bench, 3200, 3); }
+static void WalletSPScanAvgTxAvgOutputs2(benchmark::Bench& bench) { WalletSPScan(bench, 3200, 3, 2); }
+static void WalletSPScanAvgTxAvgOutputs4(benchmark::Bench& bench) { WalletSPScan(bench, 3200, 3, 4); }
+static void WalletSPScanAvgTxAvgOutputs8(benchmark::Bench& bench) { WalletSPScan(bench, 3200, 3, 8); }
 BENCHMARK(WalletSPScanMaxTxOneOutput);
 BENCHMARK(WalletSPScanOneTxMaxOutputs);
+BENCHMARK(WalletSPScanOneTxMaxOutputs2);
+BENCHMARK(WalletSPScanOneTxMaxOutputs4);
+BENCHMARK(WalletSPScanOneTxMaxOutputs8);
 BENCHMARK(WalletSPScanAvgTxAvgOutputs);
+BENCHMARK(WalletSPScanAvgTxAvgOutputs2);
+BENCHMARK(WalletSPScanAvgTxAvgOutputs4);
+BENCHMARK(WalletSPScanAvgTxAvgOutputs8);
 } // namespace wallet