#pool #async-pool #orm #database

fast_pool

The Fast Pool based on channel

3 unstable releases

0.2.0 Dec 28, 2023
0.1.9 Dec 28, 2023

#54 in Caching

Download history 588/week @ 2023-12-25 330/week @ 2024-01-01 249/week @ 2024-01-08 246/week @ 2024-01-15 140/week @ 2024-01-22 318/week @ 2024-01-29 146/week @ 2024-02-05 94/week @ 2024-02-12 296/week @ 2024-02-19 502/week @ 2024-02-26 406/week @ 2024-03-04 451/week @ 2024-03-11 369/week @ 2024-03-18 476/week @ 2024-03-25 540/week @ 2024-04-01

1,869 downloads per month
Used in 19 crates (via rbdc-pool-fast)

Apache-2.0

12KB
208 lines

fast_pool

unsafe forbidden GitHub release

a fast async pool based on channel

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

way fast_pool?

  • fast get() method performance
//windows:
//---- bench_pool stdout ----
//use Time: 4.0313ms ,each:40 ns/op
//use QPS: 24749412 QPS/s
//macos:
//---- bench_pool stdout ----
// use Time: 6.373708ms ,each:63 ns/op
// use QPS: 15683710 QPS/s

how to use this?

  • add toml
fast_pool="0.1"
async-trait = "0.1"
tokio = {version = "1",features = ["time","rt-multi-thread","macros"]}
  • 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());
}

Dependencies

~2.6–4MB
~71K SLoC