#synchronization #wait-group #btree-map #hash-map #vec #world #able

fast-able

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

84 stable releases

1.13.28 Jan 11, 2025
1.13.26 Dec 6, 2024
1.13.21 Nov 28, 2024
1.11.14 Jul 26, 2024
0.1.1 Jun 3, 2023

#206 in Concurrency

Download history 97/week @ 2024-10-02 263/week @ 2024-10-09 14/week @ 2024-10-16 347/week @ 2024-10-23 790/week @ 2024-10-30 551/week @ 2024-11-06 773/week @ 2024-11-13 1242/week @ 2024-11-20 301/week @ 2024-11-27 729/week @ 2024-12-04 175/week @ 2024-12-11 6/week @ 2024-12-18 140/week @ 2025-01-08 16/week @ 2025-01-15

156 downloads per month
Used in 2 crates

MIT/Apache

145KB
4K 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

~2.8–9MB
~72K SLoC