fix: strange compilation error leaked by compiler

Author: BinChengZhao

CHANGELOG.md

@@ -1,3 +1,8 @@
+# Version 0.10.1 
+
+## Changed
+Fix a strange compilation error that was leaked by the compiler. ([#30](https://github.com/BinChengZhao/delay-timer/issues/30)), thanks `elderbig` !
+
 # Version 0.10.0 
 
 ## Changed

Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "delay_timer"
-version = "0.10.0"
+version = "0.10.1"
 authors = ["binchengZhao <binchengZhao@outlook.com>"]
 edition = "2018"
 repository = "https://github.com/BinChengZhao/delay-timer"

examples/demo_async_std_and_tracing.rs

@@ -23,7 +23,7 @@ async fn main() -> Result<()> {
     }
 
     info!("==== All job is be init! ====");
-    for _ in 0..120 {
+    for _ in 0..300 {
         Timer::after(Duration::from_secs(60)).await;
     }
     Ok(delay_timer.stop_delay_timer()?)
@@ -32,11 +32,12 @@ async fn main() -> Result<()> {
 fn build_task_async_execute_process(task_id: u64) -> Result<Task, TaskError> {
     let mut task_builder = TaskBuilder::default();
 
+    // Remind the user to set a timeout that must be reasonable.
     let body = unblock_process_task_fn("echo hello".into());
     task_builder
         .set_frequency_by_candy(CandyFrequency::Repeated(CandyCron::Secondly))
         .set_task_id(task_id)
-        .set_maximum_running_time(10)
+        .set_maximum_running_time(2)
         .set_maximum_parallel_runnable_num(1)
         .spawn(body)
 }

src/timer/runtime_trace/sweeper.rs

@@ -139,8 +139,13 @@ impl RecyclingBins {
             .unwrap_or_else(|e| error!(" `send_timer_event` : {}", e));
     }
 
+    // FIXME: https://github.com/BinChengZhao/delay-timer/issues/28
+    // Due to the large number of tasks upstream, timeout units can pile up exceptionally high.
+    // A large amount of memory may be occupied here.
     pub(crate) async fn add_recycle_unit(self: Arc<Self>) {
         'loopLayer: loop {
+            // TODO: Internal (shrink -> cycle-bins) or change the data structure.
+
             for _ in 0..200 {
                 match self.recycle_unit_sources.recv().await {
                     Ok(recycle_unit) => {

src/timer/timer_core.rs

@@ -217,6 +217,8 @@ impl Timer {
 
             trace!("timestamp: {}, task_ids: {:?}", timestamp, task_ids);
 
+            // Centralize task processing to avoid duplicate lock requests and releases.
+            // FIXME: https://github.com/BinChengZhao/delay-timer/issues/29
             for task_id in task_ids {
                 let task_option: Option<Task>;
 

src/utils/parse.rs

@@ -4,7 +4,7 @@
 /// Collection of functions related to shell commands and processes.
 pub mod shell_command {
     use crate::prelude::*;
-    use anyhow::*;
+    use anyhow::Error as AnyhowError;
 
     use async_trait::async_trait;
 
@@ -329,7 +329,7 @@ pub mod shell_command {
     }
 
     #[cfg(SPLIT_INCLUSIVE_COMPATIBLE)]
-    fn _has_redirect_file(command: &str) -> Option<Result<File>> {
+    fn _has_redirect_file(command: &str) -> Option<Result<File, AnyhowError>> {
         let angle_bracket = if command.contains(">>") {
             ">>"
         } else if command.contains('>') {
@@ -346,14 +346,14 @@ pub mod shell_command {
     }
 
     //After confirming that there is a redirect file, parse the command before the command '>'.
-    fn _remove_angle_bracket_command(command: &str) -> Result<&str> {
+    fn _remove_angle_bracket_command(command: &str) -> Result<&str, AnyhowError> {
         let mut sub_command_inner = command.trim().split('>');
         sub_command_inner
             .next()
             .ok_or_else(|| anyhow!("can't parse ...."))
     }
 
-    fn create_stdio_file(angle_bracket: &str, filename: &str) -> Result<File> {
+    fn create_stdio_file(angle_bracket: &str, filename: &str) -> Result<File, AnyhowError> {
         let mut file_tmp = OpenOptions::new();
         file_tmp.write(true).create(true);