fast_pool

a fast async pool based on channel

• support get(),get_timeout(),state() methods
• support atomic max_open(Resize freely)
• based on flume

why fast_pool?

• fast get() method performance

//---- bench_pool windows ----
//Time: 14.0994ms ,each:130 ns/op
//QPS: 7086167 QPS/s
//---- bench_pool linux ----
//Time: 11.437625ms ,each:114 ns/op
//QPS: 8736453 QPS/s

• Implement using only channels
• no additional threads
• Support asynchronous/tokio

how to use this?

• step 1 add toml

fast_pool="0.3"
tokio = {version = "1",features = ["time","rt-multi-thread","macros"]}

• step 2 impl trait

use std::ops::{DerefMut};
use std::time::Duration;
use async_trait::async_trait;
use fast_pool::{Manager, Pool};

#[derive(Debug)]
pub struct TestManager {}

impl Manager for TestManager {
    type Connection = String;
    type Error = String;

    async fn connect(&self) -> Result<Self::Connection, Self::Error> {
        Ok("conn".to_string())
    }

    async fn check(&self, conn: &mut Self::Connection) -> Result<(), Self::Error> {
        //check should use conn.ping()
        if conn == "error" {
            return Err(Self::Error::from("error".to_string()));
        }
        Ok(())
    }
}

#[tokio::main]
async fn main() {
    let p = Pool::new(TestManager {});
    println!("status = {}",p.state());
    p.set_max_open(10);
    println!("status = {}",p.state());

    let mut conn = p.get().await.unwrap();
    println!("conn = {}",conn.deref_mut());
    let mut conn = p.get_timeout(Some(Duration::from_secs(1))).await.unwrap();
    println!("conn = {}",conn.deref_mut());
}