Change rust edition to 2024 and format code

Author: frostyplanet

Cargo.toml

@@ -2,7 +2,7 @@
 name = "crossfire"
 version = "1.0.3"
 authors = ["plan <frostyplanet@gmail.com>"]
-edition = "2018"
+edition = "2024"
 license = "Apache-2.0"
 homepage = "https://github.com/frostyplanet/crossfire-rs"
 readme = "README.md"

rustfmt.toml

@@ -1,5 +1,4 @@
-#unstable_features = true
-edition = "2018"
+edition = "2024"
 fn_params_layout = "Compressed"
 newline_style = "Unix"
 use_small_heuristics = "Max"

src/channel/locked_waker.rs

@@ -1,6 +1,6 @@
 use std::sync::{
-    atomic::{AtomicBool, Ordering},
     Arc, Weak,
+    atomic::{AtomicBool, Ordering},
 };
 use std::task::*;
 

src/mpmc/bounded.rs

@@ -3,8 +3,8 @@ use super::tx::*;
 use crate::channel::*;
 use crossbeam::queue::SegQueue;
 use std::sync::{
-    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
     Arc,
+    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
 };
 use std::task::*;
 
@@ -309,8 +309,11 @@ mod tests {
         }
         let end = Instant::now();
 
-        println!("{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
-                 total_message, (total_message as f64) / end.duration_since(start).as_secs_f64());
+        println!(
+            "{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
+            total_message,
+            (total_message as f64) / end.duration_since(start).as_secs_f64()
+        );
     }
 
     #[test]

src/mpmc/mod.rs

@@ -3,11 +3,11 @@ pub use tx::*;
 mod rx;
 pub use rx::*;
 mod bounded;
+pub use bounded::{SharedFutureBoth, SharedSenderBRecvF, SharedSenderFRecvB};
 pub use bounded::{
     bounded_future_both, bounded_tx_blocking_rx_future, bounded_tx_future_rx_blocking,
 };
-pub use bounded::{SharedFutureBoth, SharedSenderBRecvF, SharedSenderFRecvB};
 mod unbounded;
-pub use unbounded::{unbounded_future, RxUnbounded, TxUnbounded, UnboundedSharedFuture};
+pub use unbounded::{RxUnbounded, TxUnbounded, UnboundedSharedFuture, unbounded_future};
 
 pub use crate::channel::{AsyncRx, LockedWaker};

src/mpmc/unbounded.rs

@@ -3,8 +3,8 @@ use super::tx::*;
 use crate::channel::*;
 use crossbeam::queue::SegQueue;
 use std::sync::{
-    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
     Arc,
+    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
 };
 use std::task::*;
 
@@ -125,8 +125,11 @@ mod tests {
         }
         let end = Instant::now();
 
-        println!("{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
-                 total_message, (total_message as f64) / end.duration_since(start).as_secs_f64());
+        println!(
+            "{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
+            total_message,
+            (total_message as f64) / end.duration_since(start).as_secs_f64()
+        );
     }
 
     #[test]
@@ -271,7 +274,7 @@ mod tests {
 
     #[test]
     fn test_tx_unbounded_idle_select() {
-        use futures::{pin_mut, select, FutureExt};
+        use futures::{FutureExt, pin_mut, select};
         let rt = tokio::runtime::Builder::new_multi_thread()
             .worker_threads(2)
             .enable_all()

src/mpsc/bounded.rs

@@ -3,8 +3,8 @@ use super::tx::*;
 use crate::channel::*;
 use crossbeam::queue::{ArrayQueue, SegQueue};
 use std::sync::{
-    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
     Arc,
+    atomic::{AtomicBool, AtomicU64, AtomicUsize, Ordering},
 };
 use std::task::*;
 
@@ -350,8 +350,11 @@ mod tests {
         }
         let end = Instant::now();
 
-        println!("{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
-                 total_message, (total_message as f64) / end.duration_since(start).as_secs_f64());
+        println!(
+            "{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
+            total_message,
+            (total_message as f64) / end.duration_since(start).as_secs_f64()
+        );
     }
 
     #[test]

src/mpsc/mod.rs

@@ -3,9 +3,9 @@ pub use tx::*;
 mod rx;
 pub use rx::*;
 mod bounded;
+pub use bounded::{SharedFutureBoth, SharedSenderBRecvF, SharedSenderFRecvB};
 pub use bounded::{
     bounded_future_both, bounded_tx_blocking_rx_future, bounded_tx_future_rx_blocking,
 };
-pub use bounded::{SharedFutureBoth, SharedSenderBRecvF, SharedSenderFRecvB};
 mod unbounded;
-pub use unbounded::{unbounded_future, RxUnbounded, TxUnbounded, UnboundedSharedFuture};
+pub use unbounded::{RxUnbounded, TxUnbounded, UnboundedSharedFuture, unbounded_future};

src/mpsc/unbounded.rs

@@ -3,8 +3,8 @@ use super::tx::*;
 use crate::channel::*;
 use crossbeam::queue::ArrayQueue;
 use std::sync::{
-    atomic::{AtomicUsize, Ordering},
     Arc,
+    atomic::{AtomicUsize, Ordering},
 };
 use std::task::*;
 
@@ -100,8 +100,11 @@ mod tests {
         }
         let end = Instant::now();
 
-        println!("{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
-                 total_message, (total_message as f64) / end.duration_since(start).as_secs_f64());
+        println!(
+            "{} message, single sender thread single receiver thread use std::sync::sync_channel, cost time:{} s",
+            total_message,
+            (total_message as f64) / end.duration_since(start).as_secs_f64()
+        );
     }
 
     #[test]