upgrade all deps

Author: smallnest

channel/Cargo.toml

@@ -8,7 +8,6 @@ edition = "2021"
 [dependencies]
 async-channel = "1.7.1"
 async-priority-channel = "0.1.0"
-atomic_mpmc = "0.2.0"
 broadcaster = "1.0.0"
 crossfire = "0.1.7"
 flume = "0.10.14"

channel/src/main.rs

@@ -8,7 +8,6 @@ fn main() {
 
     crossfire_mpsc();
     crossfire_mpmc();
-    atomic_mpmc();
     flume_example();
     async_channel_example();
     async_priority_channel_example();

channel/src/others.rs

@@ -74,49 +74,7 @@ pub fn crossfire_mpmc() {
     });
 }
 
-// rx can't aware tx close
-pub fn atomic_mpmc() {
-    // let (tx, rx) = channel::<i32>(10);
-
-    // let mut sender_handles = vec![];
-    // for v in 0..4 {
-    //     let tx = tx.clone();
-    //     let handle = thread::spawn(move || {
-    //         for i in 0i32..10 {
-    //             if i % 5 != v {
-    //                 continue;
-    //             }
-    //             let _ = tx.send(i).unwrap();
-    //             println!("thread {} atomic_mpmc sent {}", v, i);
-    //         }
-    //     });
-
-    //     sender_handles.push(handle);
-    // }
-
-    // let mut handles = vec![];
-    // for i in 0..4 {
-    //     let rx = rx.clone();
-    //     let handle = thread::spawn(move || loop {
-    //         if let Ok(_i) = rx.recv() {
-    //             println!("atomic_mpmc thread {} recv {}", i, _i);
-    //         } else {
-    //             println!("atomic_mpmc rx closed");
-    //             break;
-    //         }
-    //     });
-    //     handles.push(handle);
-    // }
-
-    // for handle in sender_handles {
-    //     handle.join().unwrap();
-    // }
-    // drop((tx,rx));
-
-    // for handle in handles {
-    //     handle.join().unwrap();
-    // }
-}
+
 
 // has issues.
 pub fn broadcaster() {

special/Cargo.toml

@@ -27,7 +27,7 @@ futures = "0.3.25"
 oneshot = "0.1.5"
 portable-atomic = { version = "0.3", features=["float"] }
 process_lock = "0.1.0"
-scc = "0.11.1"
+scc = "1.5.0"
 sharded-slab = "0.1.4"
 simple-mutex = "1.1.5"
 singleflight = "0.2.0"