add option for cpu thread pinning

README.md

@@ -83,6 +83,9 @@ timeout: 5000  # default 5000ms
 
 # delay after disks will be woken up (if 0 no wakeup) [s]
 wakeup_after: 240  # default 240s
+
+# pin worker threads to cpu cores
+cpu_thread_pinning: false # pin worker threads to cpu cores | default false
 ```
 
 ### Donate 

config.yaml

@@ -25,6 +25,8 @@ logfile_max_size : 20                 # maximum size per logfile in MiB
 console_log_pattern: '{({d(%H:%M:%S)} [{l}]):16.16} {m}{n}'
 logfile_log_pattern: '{({d(%Y-%m-%d %H:%M:%S)} [{l}]):26.26} {m}{n}'
 
+cpu_thread_pinning: false # default false
+
 # More detailed log patterns
 #console_log_pattern: '{d(%H:%M:%S.%3f%z)} [{h({l}):<5}] [{T}] [{t}] - {M}:{m}{n}'
 #logfile_log_pattern: '{d(%Y-%m-%dT%H:%M:%S.%3f%z)} [{h({l}):<5}] [{T}]-[{t}] [{f}:{L}] - {M}:{m}{n}'

src/config.rs

@@ -56,6 +56,9 @@ pub struct Cfg {
 
     #[serde(default = "default_logfile_log_level")]
     pub logfile_log_level: String,
+
+    #[serde(default = "default_cpu_thread_pinning")]
+    pub cpu_thread_pinning: bool,
 }
 
 fn default_secret_phrase() -> String {
@@ -118,6 +121,10 @@ fn default_wakeup_after() -> i64 {
     240
 }
 
+fn default_cpu_thread_pinning() -> bool {
+    false
+}
+
 pub fn load_cfg(config: &str) -> Cfg {
     let cfg_str = fs::read_to_string(config).expect("failed to open config");
     let cfg: Cfg = serde_yaml::from_str(&cfg_str).expect("failed to parse config");

src/miner.rs

@@ -138,7 +138,9 @@ impl Miner {
         for id in 0..worker_thread_count {
             let core_id = core_ids[id % core_ids.len()];
             thread::spawn({
-                core_affinity::set_for_current(core_id);
+                if cfg.cpu_thread_pinning {
+                    core_affinity::set_for_current(core_id);
+                }
 
                 create_worker_task(
                     rx_read_replies.clone(),