run executor with the number of CPUs available

src/bin/cashierd.rs

@@ -750,9 +750,13 @@ async fn main() -> Result<()> {
 
     let get_address_flag = args.is_present("ADDRESS");
 
+    let nthreads = num_cpus::get();
+    debug!(target: "GATEWAY DAEMON", "Run {} executor threads", nthreads);
+
     let (_, result) = Parallel::new()
-        // Run four executor threads.
-        .each(0..3, |_| smol::future::block_on(ex.run(shutdown.recv())))
+        .each(0..nthreads, |_| {
+            smol::future::block_on(ex.run(shutdown.recv()))
+        })
         // Run the main future on the current thread.
         .finish(|| {
             smol::future::block_on(async move {

src/bin/darkfid.rs

@@ -611,9 +611,13 @@ async fn main() -> Result<()> {
 
     let ex2 = ex.clone();
 
+    let nthreads = num_cpus::get();
+    debug!(target: "GATEWAY DAEMON", "Run {} executor threads", nthreads);
+
     let (_, result) = Parallel::new()
-        // Run four executor threads.
-        .each(0..3, |_| smol::future::block_on(ex.run(shutdown.recv())))
+        .each(0..nthreads, |_| {
+            smol::future::block_on(ex.run(shutdown.recv()))
+        })
         // Run the main future on the current thread.
         .finish(|| {
             smol::future::block_on(async move {

src/bin/gatewayd.rs

@@ -4,6 +4,7 @@ use std::sync::Arc;
 use async_executor::Executor;
 use clap::clap_app;
 use easy_parallel::Parallel;
+use log::debug;
 
 use drk::{
     blockchain::{rocks::columns, Rocks, RocksColumn},
@@ -57,9 +58,13 @@ async fn main() -> Result<()> {
 
     let ex2 = ex.clone();
 
+    let nthreads = num_cpus::get();
+    debug!(target: "GATEWAY DAEMON", "Run {} executor threads", nthreads);
+
     let (_, result) = Parallel::new()
-        // Run four executor threads.
-        .each(0..3, |_| smol::future::block_on(ex.run(shutdown.recv())))
+        .each(0..nthreads, |_| {
+            smol::future::block_on(ex.run(shutdown.recv()))
+        })
         // Run the main future on the current thread.
         .finish(|| {
             smol::future::block_on(async move {