Эх сурвалжийг харах

错开定时计算任务的执行时间

JiahengHe 1 жил өмнө
parent
commit
9e7911cb05

+ 1 - 1
src/binance_usdt_swap_data_listener.rs

@@ -75,7 +75,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(55)).await;
         }
     });
     // 定时删除数据

+ 1 - 1
src/bitget_usdt_swap_data_listener.rs

@@ -75,7 +75,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(70)).await;
         }
     });
     // 定时删除数据

+ 1 - 1
src/bybit_usdt_swap_data_listener.rs

@@ -76,7 +76,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(65)).await;
         }
     });
     // 定时删除数据

+ 1 - 1
src/gate_coin_spot_data_listener.rs

@@ -77,7 +77,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(70)).await;
         }
     });
     // 定时删除数据

+ 1 - 1
src/gate_usdt_swap_data_listener.rs

@@ -78,7 +78,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(55)).await;
         }
     });
     // 定时删除数据

+ 1 - 1
src/mexc_usdt_swap_data_listener.rs

@@ -80,7 +80,7 @@ pub async fn run_listener(is_shutdown_arc: Arc<AtomicBool>) {
                 let mut indicator_map = INDICATOR_MAP.lock().await;
                 indicator_map.insert(symbol, msv);
             }
-            tokio::time::sleep(Duration::from_secs(60)).await;
+            tokio::time::sleep(Duration::from_secs(65)).await;
         }
     });
     // 定时删除数据