#vec #wait-group #btree-map #唯快不破 #2347872

bin+lib fast-able

The world's martial arts are fast and unbreakable; 天下武功 唯快不破

115 stable releases

new 1.17.1 Apr 18, 2025
1.15.8 Mar 12, 2025
1.13.26 Dec 6, 2024
1.13.21 Nov 28, 2024
0.1.1 Jun 3, 2023

#136 in Concurrency

Download history 146/week @ 2025-01-10 10/week @ 2025-01-17 4/week @ 2025-01-31 71/week @ 2025-02-07 1434/week @ 2025-02-14 151/week @ 2025-02-21 431/week @ 2025-02-28 637/week @ 2025-03-07 176/week @ 2025-03-14 10/week @ 2025-03-21 1/week @ 2025-03-28 581/week @ 2025-04-11

594 downloads per month
Used in 2 crates

MIT/Apache

180KB
4.5K SLoC

sync-data

sync-data is a high-performance synchronization library

  • SyncHashMap (sync HashMap)
  • SyncBtreeMap (sync BtreeMap)
  • SyncVec (sync Vec)
  • WaitGroup (async/blocking all support WaitGroup)

for example:

    pub static RECKON_BY_SEC: once_cell::sync::Lazy<Statis> =
    once_cell::sync::Lazy::new(|| Statis::new(|v| println!("one sec run sum: {v}")));

// one sec run sum: 2347872
#[test]
fn bench_insert_mul_thread() {
    // common_uu::log4rs_mod::init().unwrap();
    let rw = Arc::new(SyncHashMap::new(Some(10)));
    rw.insert(1, 1);
    assert_eq!(rw.len(), 1);

    let rw2 = rw.clone();
    let rt1 = std::thread::spawn(move || {
        for i in 0..5_0000_0000_u64 {
            rw2.insert(i, i + 1);
            RECKON_BY_SEC.add();
        }
    });

    let rw2 = rw.clone();
    let rt2 = std::thread::spawn(move || {
        for i in 5_0000_0000..10_0000_0000_u64 {
            rw2.insert(i, i + 1);
            RECKON_BY_SEC.add();
        }
    });

    let rw2 = rw.clone();
    let rt3 = std::thread::spawn(move || {
        for i in 10_0000_0000_u64..50_0000_0000_u64 {
            rw2.insert(i, i + 1);
            RECKON_BY_SEC.add();
        }
    });


    rt1.join();
}

wait group:

use std::time::Duration;
use tokio::time::sleep;
use fast_able::wg::WaitGroup;
#[tokio::test]
async fn test_wg() {
    let wg = WaitGroup::new();
    let wg2 = wg.clone();
    tokio::spawn(async move {
        sleep(Duration::from_secs(1)).await;
        drop(wg2);
    });
    let wg2 = wg.clone();
    tokio::spawn(async move {
        sleep(Duration::from_secs(1)).await;
        drop(wg2);
    });
    wg.wait_async().await;
    println!("all done");
}

Dependencies

~3–8.5MB
~79K SLoC