replace std::thread::sleep with tokio::time::sleep in async functions

Cargo.toml

@@ -28,7 +28,7 @@ num_cpus = "1.16.0"
 rlimit = "0.10.1"
 serde = { version = "1.0.188", features = ["serde_derive"] }
 serde_json = "1.0.107"
-tokio = { version = "1.32.0", features = ["full"] }
+tokio = { version = "1.36.0", features = ["full"] }
 itertools = "0.11.0"
 rand = "0.8.5"
 env_logger = "0.10.0"

src/main.rs

@@ -103,7 +103,7 @@ async fn main() -> Result<(), session::Error> {
 
     let one_sec = time::Duration::from_secs(1);
     while !session.is_finished() {
-        std::thread::sleep(one_sec);
+        tokio::time::sleep(one_sec).await;
     }
 
     log::info!("runtime {:?}", start.elapsed());

src/plugins/manager.rs

@@ -125,7 +125,7 @@ async fn worker(
                     .gen_range(session.options.jitter_min..=session.options.jitter_max);
                 if ms > 0 {
                     log::debug!("jitter of {} ms", ms);
-                    std::thread::sleep(time::Duration::from_millis(ms));
+                    tokio::time::sleep(time::Duration::from_millis(ms)).await;
                 }
             }
 
@@ -144,7 +144,7 @@ async fn worker(
                                 session.options.retries,
                                 err
                             );
-                            std::thread::sleep(retry_time);
+                            tokio::time::sleep(retry_time).await;
                             continue;
                         } else {
                             // add this target to the list of unreachable in order to avoi

src/session/mod.rs

@@ -27,7 +27,7 @@ async fn periodic_saver(session: Arc<Session>) {
     let persistent = session.options.session.is_some();
 
     while !session.is_stop() {
-        std::thread::sleep(one_sec);
+        tokio::time::sleep(one_sec).await;
 
         // compute number of attempts per second
         let new_done = session.get_done();