change to flume

Cargo.toml

@@ -1,7 +1,7 @@
 workspace = { members = ["example"] }
 [package]
 name = "fast_pool"
-version = "0.1.2"
+version = "0.1.3"
 edition = "2021"
 description = "The Fast Pool based on channel"
 readme = "README.md"
@@ -17,5 +17,5 @@ async-trait = "0.1"
 futures-core = { version = "0.3" }
 tokio = {version = "1",features = ["time","rt-multi-thread","macros"]}
 num_cpus = {version = "1.16.0"}
-crossfire = "1.0.1"
+flume = { version = "0.11.0", default-features = false, features = ["async"] }
 [dev-dependencies]

README.md

@@ -8,7 +8,7 @@
 a fast async pool based on channel
 * support `get()`,`get_timeout()`,`state()` methods
 * support atomic max_open(Resize freely)
-* based on [crossbeam channel(crossfire)](https://crates.io/crates/crossfire)
+* based on [flume](https://crates.io/crates/flume)
 
 ### way fast_pool?
 

src/lib.rs

@@ -2,18 +2,18 @@
 mod defer;
 
 use async_trait::async_trait;
-use crossfire::mpmc::{RxUnbounded, TxUnbounded};
 use std::fmt::{Debug, Formatter};
 use std::ops::{Deref, DerefMut};
 use std::sync::atomic::{AtomicU64, Ordering};
 use std::sync::Arc;
 use std::time::Duration;
+use flume::{Receiver, Sender};
 
 /// Pool have manager, get/get_timeout Connection from Pool
 pub struct Pool<M: Manager> {
     manager: Arc<M>,
-    idle_send: Arc<TxUnbounded<M::Connection>>,
-    idle_recv: Arc<RxUnbounded<M::Connection>>,
+    idle_send: Arc<Sender<M::Connection>>,
+    idle_recv: Arc<Receiver<M::Connection>>,
     max_open: Arc<AtomicU64>,
     in_use: Arc<AtomicU64>,
     waits: Arc<AtomicU64>,
@@ -61,7 +61,7 @@ impl<M: Manager> Pool<M> {
         <M as Manager>::Connection: Unpin,
     {
         let default_max = num_cpus::get() as u64 * 4;
-        let (s, r) = crossfire::mpmc::unbounded_future();
+        let (s, r) = flume::unbounded();
         Self {
             manager: Arc::new(m),
             idle_send: Arc::new(s),
@@ -91,7 +91,7 @@ impl<M: Manager> Pool<M> {
                     .map_err(|e| M::Error::from(&e.to_string()))?;
             }
             self.idle_recv
-                .recv()
+                .recv_async()
                 .await
                 .map_err(|e| M::Error::from(&e.to_string()))
         };
@@ -146,7 +146,7 @@ impl<M: Manager> Pool<M> {
 
 pub struct ConnectionBox<M: Manager> {
     pub inner: Option<M::Connection>,
-    sender: Arc<TxUnbounded<M::Connection>>,
+    sender: Arc<Sender<M::Connection>>,
     in_use: Arc<AtomicU64>,
     max_open: Arc<AtomicU64>,
 }