#async-trait #traits #async #sync #abstraction #async-await #abs

nightly no-std abs_sync

Abstraction of synchronization for rust async/await

1 unstable release

0.1.0 Oct 9, 2024

#266 in No standard library

Download history 113/week @ 2024-10-03 77/week @ 2024-10-10 22/week @ 2024-10-17 7/week @ 2024-10-24 13/week @ 2024-10-31

232 downloads per month
Used in 6 crates (2 directly)

MIT/Apache

21KB
565 lines

abs_sync

Abstraction of synchronization for Rust async/await.

This crate provide traits about locks in sync and/or async environment.

Example

use core::{
    borrow::BorrowMut,
    ops::{ControlFlow, Deref, DerefMut},
};

use pin_utils::pin_mut;
use abs_sync::{
    cancellation::{NonCancellableToken, TrIntoFutureMayCancel},
    x_deps::pin_utils,
};

async fn demo<B, L, T>(rwlock: B)
where
    B: BorrowMut<L>,
    L: TrAsyncRwLock<Target = T>,
{
    let acq = rwlock.borrow().acquire();
    pin_mut!(acq);
    let read_async = acq.as_mut().read_async();
    // let write_async = acq.write_async(); // illegal
    let ControlFlow::Continue(read_guard) = read_async
        .may_cancel_with(NonCancellableToken::pinned())
        .await
        .branch()
    else {
        panic!()
    };
    let _ = read_guard.deref();
    // let write_async = acq.write_async(); // illegal
    drop(read_guard);
    let ControlFlow::Continue(upgradable) = acq
        .as_mut()
        .upgradable_read_async()
        .may_cancel_with(NonCancellableToken::pinned())
        .await
        .branch()
    else {
        panic!()
    };
    let _ = upgradable.deref();
    let upgrade = upgradable.upgrade();
    pin_mut!(upgrade);
    let ControlFlow::Continue(mut write_guard) = upgrade
        .upgrade_async()
        .may_cancel_with(NonCancellableToken::pinned())
        .await
        .branch()
    else {
        panic!()
    };
    let _ = write_guard.deref_mut();
    let upgradable = write_guard.downgrade_to_upgradable();
    drop(upgradable)
}

Dependencies

~0.4–0.9MB
~20K SLoC