chore: Optimize code.

Author: BinChengZhao

src/timer/runtime_trace/sweeper.rs

@@ -101,17 +101,16 @@ impl RecyclingBins {
             let now: u64 = timestamp();
             let mut duration: Option<Duration> = None;
             for _ in 0..200 {
-                if let Some(recycle_flag) = (&recycle_unit_heap).peek().map(|r| r.0.deadline <= now)
-                {
+                if let Some(recycle_flag) = recycle_unit_heap.peek().map(|r| r.0.deadline <= now) {
                     if !recycle_flag {
-                        duration = (&recycle_unit_heap)
+                        duration = recycle_unit_heap
                             .peek()
                             .map(|r| r.0.deadline - now)
                             .map(Duration::from_secs);
                         break;
                     }
 
-                    if let Some(recycle_unit) = (&mut recycle_unit_heap).pop().map(|v| v.0) {
+                    if let Some(recycle_unit) = recycle_unit_heap.pop().map(|v| v.0) {
                         //handle send-error.
                         self.send_timer_event(TimerEvent::TimeoutTask(
                             recycle_unit.task_id,
@@ -151,7 +150,7 @@ impl RecyclingBins {
                     Ok(recycle_unit) => {
                         let mut recycle_unit_heap = self.recycle_unit_heap.lock().await;
 
-                        (&mut recycle_unit_heap).push(Reverse(recycle_unit));
+                        recycle_unit_heap.push(Reverse(recycle_unit));
                     }
 
                     Err(_) => {

src/timer/runtime_trace/task_handle.rs

@@ -287,7 +287,7 @@ use tokio::task::JoinHandle;
 //TODO:remove debug.
 impl<T: Send + Sync + Debug + 'static> DelayTaskHandler for JoinHandle<T> {
     fn quit(self: Box<Self>) -> Result<()> {
-        (&*self).abort();
+        (*self).abort();
         Ok(())
     }
 }

src/timer/task.rs

@@ -570,7 +570,7 @@ impl<F: Fn() -> U + 'static + Send, U: Future + 'static + Send> Routine for Asyn
 
     #[inline(always)]
     fn spawn_by_tokio(&self, task_context: TaskContext) -> Self::TokioHandle {
-        let user_future = (&self.0)();
+        let user_future = self.0();
 
         async_spawn_by_tokio({
             let task_id = task_context.task_id;
@@ -589,7 +589,7 @@ impl<F: Fn() -> U + 'static + Send, U: Future + 'static + Send> Routine for Asyn
 
     #[inline(always)]
     fn spawn_by_smol(&self, task_context: TaskContext) -> Self::SmolHandle {
-        let user_future = (&self.0)();
+        let user_future = self.0();
 
         async_spawn_by_smol({
             let task_id = task_context.task_id;
@@ -623,7 +623,7 @@ impl<F: Fn() + 'static + Send + Clone> Routine for SyncFn<F> {
 
     #[inline(always)]
     fn spawn_by_tokio(&self, task_context: TaskContext) -> Self::TokioHandle {
-        let fn_handle = unblock_spawn_by_tokio((&self.0).clone());
+        let fn_handle = unblock_spawn_by_tokio(self.0.clone());
 
         let task_id = task_context.task_id;
         let record_id = task_context.record_id;
@@ -645,7 +645,7 @@ impl<F: Fn() + 'static + Send + Clone> Routine for SyncFn<F> {
 
     #[inline(always)]
     fn spawn_by_smol(&self, task_context: TaskContext) -> Self::SmolHandle {
-        let fn_handle = unblock_spawn_by_smol((&self.0).clone());
+        let fn_handle = unblock_spawn_by_smol(self.0.clone());
 
         let task_id = task_context.task_id;
         let record_id = task_context.record_id;

src/utils/parse.rs

@@ -63,10 +63,7 @@ pub mod shell_command {
     /// Abstraction of command methods in multiple libraries.
     pub trait CommandUnify<Child: ChildUnify>: Sized {
         /// Constructs a new Command for launching the program at path program.
-        // FIXME:
-        fn new<S: AsRef<OsStr>>(program: S) -> Self {
-            Self::new(program.as_ref())
-        }
+        fn new<S: AsRef<OsStr>>(program: S) -> Self;
 
         /// Adds multiple arguments to pass to the program.
         fn args<I, S>(&mut self, args: I) -> &mut Self