#container #tokio #wait-group #async #btree-map #vec #read-write

dark-std

dark-std is an Implementation of asynchronous containers build on tokio. It uses a read-write separation design borrowed from Golang

4 releases

0.2.16 Jul 7, 2024
0.2.14 May 3, 2024
0.2.11 Mar 15, 2024
0.2.9 Dec 11, 2023
0.1.2 Mar 13, 2022

#123 in Asynchronous

Download history 1089/week @ 2024-04-02 1034/week @ 2024-04-09 773/week @ 2024-04-16 1018/week @ 2024-04-23 1211/week @ 2024-04-30 882/week @ 2024-05-07 630/week @ 2024-05-14 957/week @ 2024-05-21 1023/week @ 2024-05-28 1157/week @ 2024-06-04 1457/week @ 2024-06-11 1169/week @ 2024-06-18 1142/week @ 2024-06-25 1671/week @ 2024-07-02 1353/week @ 2024-07-09 1013/week @ 2024-07-16

5,405 downloads per month
Used in 32 crates (5 directly)

MIT/Apache

51KB
1.5K SLoC

dark-std

dark-std is an Implementation of asynchronous

  • defer! (defer macro)
  • SyncHashMap (async HashMap)
  • SyncBtreeMap (async BtreeMap)
  • SyncVec (async Vec)
  • WaitGroup (async/blocking all support WaitGroup)
  • AtomicDuration (atomic duration)

for example:

    #[tokio::test]
    pub async fn test_get() {
        let m = SyncHashMap::<i32, i32>::new();
        let insert = m.insert(1, 2);
        
        let g = m.get(&1).unwrap();//don't need lock and await
        assert_eq!(&2, g);
    }

wait group:

use std::time::Duration;
use tokio::time::sleep;
use dark_std::sync::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

~1.4–7MB
~37K SLoC