refactor(main): improve 60%+

raw = 145.710541ms
new = 88.962291ms

Author: pan93412

example-rust/src/main.rs

@@ -48,31 +48,40 @@ async fn main() -> std::io::Result<()> {
     let start = std::time::Instant::now();
     let path = glob(FILE_DIR).expect("failed to read glob pattern");
 
-    let submissions = path.map(|entry| async {
-        let yaml_path = entry.expect("should be existed");
-        let txt_path = yaml_path.with_extension("txt");
-
-        let outdir_submission = async { create_outdir().await.expect("unable to create outdir") };
-
-        let read_text_file_submission = async {
-            let data = read_file(&txt_path).await;
-            let tokens = get_unique_token(&data);
-
-            tokens.join("\n")
-        };
-
-        let filename_submission = async {
-            get_filename_from_meta(&yaml_path)
-                .await
-                .expect("should be existed")
-        };
-
-        let (tokens, filename, _) = tokio::join!(
-            read_text_file_submission,
-            filename_submission,
-            outdir_submission,
-        );
-        fs::write(filename, tokens).await.expect("failed to write");
+    let submissions = path.map(|entry| {
+        tokio::spawn(async {
+            let yaml_path = entry.expect("should be existed");
+            let txt_path = yaml_path.with_extension("txt");
+
+            let outdir_submission =
+                tokio::spawn(async { create_outdir().await.expect("unable to create outdir") });
+
+            let read_text_file_submission = tokio::spawn(async move {
+                let data = read_file(&txt_path).await;
+                let tokens = get_unique_token(&data);
+
+                tokens.join("\n")
+            });
+
+            let filename_submission = tokio::spawn(async move {
+                get_filename_from_meta(&yaml_path)
+                    .await
+                    .expect("should be existed")
+            });
+
+            let (tokens, filename, _) = tokio::join!(
+                read_text_file_submission,
+                filename_submission,
+                outdir_submission,
+            );
+
+            fs::write(
+                filename.expect("failed to run filename"),
+                tokens.expect("failed to get tokens"),
+            )
+            .await
+            .expect("failed to write");
+        })
     });
 
     futures::future::join_all(submissions).await;