refactor(ui): 移除不必要的debug打印并优化task运行逻辑

Author: hubertshelley

silent/src/scheduler/mod.rs

@@ -8,7 +8,7 @@ use anyhow::{Result, anyhow};
 use std::sync::{Arc, LazyLock};
 use std::thread;
 use tokio::sync::Mutex;
-use tracing::{debug, error, info};
+use tracing::{error, info};
 
 pub use process_time::ProcessTime;
 pub use task::Task;
@@ -75,10 +75,7 @@ impl Scheduler {
             if task.is_async {
                 tokio::spawn(async move {
                     match task.clone().run_async().await {
-                        Ok(_) => debug!(
-                            "task: ID:{:?} Description:{:?} ProcessTime:{:?} activate success!",
-                            task.id, task.description, task.process_time
-                        ),
+                        Ok(_) => {}
                         Err(e) => error!(
                             "task: ID:{:?} Description:{:?} ProcessTime:{:?} run failed! error: {:?}",
                             task.id, task.description, task.process_time, e
@@ -87,10 +84,7 @@ impl Scheduler {
                 });
             } else {
                 thread::spawn(move || match task.clone().run() {
-                    Ok(_) => debug!(
-                        "task: ID:{:?} Description:{:?} ProcessTime:{:?} activate success!",
-                        task.id, task.description, task.process_time
-                    ),
+                    Ok(_) => {}
                     Err(e) => error!(
                         "task: ID:{:?} Description:{:?} ProcessTime:{:?} run failed! error: {:?}",
                         task.id, task.description, task.process_time, e

silent/src/scheduler/task.rs

@@ -5,6 +5,7 @@ use std::fmt::Debug;
 use std::future::Future;
 use std::pin::Pin;
 use std::sync::Arc;
+use tracing::debug;
 
 pub type JobToRun = dyn Fn() -> Result<()> + Send + Sync;
 pub type JobToRunAsync = dyn Fn() -> Pin<Box<dyn Future<Output = Result<()>> + Send>> + Send + Sync;
@@ -38,15 +39,27 @@ impl Task {
         match self.is_async {
             true => Err(anyhow::anyhow!("async task not support run")),
             false => match self.process_time.is_active() {
-                true => self.action.clone()(),
+                true => {
+                    debug!(
+                        "task: ID:{:?} Description:{:?} ProcessTime:{:?} activate success!",
+                        self.id, self.description, self.process_time
+                    );
+                    self.action.clone()()
+                }
                 false => Ok(()),
             },
         }
     }
     pub(crate) async fn run_async(&self) -> Result<()> {
         match self.is_async {
             true => match self.process_time.is_active() {
-                true => self.action_async.clone()().await,
+                true => {
+                    debug!(
+                        "async task: ID:{:?} Description:{:?} ProcessTime:{:?} activate success!",
+                        self.id, self.description, self.process_time
+                    );
+                    self.action_async.clone()().await
+                }
                 false => Ok(()),
             },
             false => Err(anyhow::anyhow!("sync task not support run_async")),