Reduce parallelism when fetches txs in mempool for bitcoind backend (#4257)

This commit is contained in:
Chris Stewart 2022-04-13 09:18:32 -05:00 committed by GitHub
parent 3d86276902
commit 10157d108f
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23

View File

@ -389,7 +389,7 @@ object BitcoindRpcBackendUtil extends Logging {
{
if (processing.compareAndSet(false, true)) {
logger.debug("Polling bitcoind for mempool")
val numParallelism = Runtime.getRuntime.availableProcessors() * 2
val numParallelism = Runtime.getRuntime.availableProcessors()
//don't want to execute these in parallel
val processTxFlow = Sink.foreachAsync[Transaction](1)(processTx)