Struct tokio_lk::Lock

pub struct Lock<T> where
    Lock<T>: Destruct<T>,  { /* fields omitted */ }

Lock future struct

The lock future refers to shared map to support lock-by-id functionality

Methods

impl<T: Clone> Lock<T> where
    Lock<T>: Destruct<T>,
    AsyncInsert<T>: Future<Output = Arc<(AtomicUsize, AtomicUsize, AtomicSerialWaker)>>, 

pub async fn fnew(target: usize, map: KeyPool<T>) -> Self

Create a Lock instance on the future's result

Trait Implementations

impl<T: Clone> Clone for Lock<T> where
    Lock<T>: Destruct<T>, 

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T: Debug> Debug for Lock<T> where
    Lock<T>: Destruct<T>, 

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl Destruct<Arc<Mutex<HashMap<usize, Arc<(AtomicUsize, AtomicUsize, AtomicSerialWaker)>, RandomState>>>> for Lock<MapType>

fn destruct(&mut self)

impl<T> Destruct<T> for Lock<T>

fn destruct(&mut self)

impl<T> Drop for Lock<T> where
    Lock<T>: Destruct<T>, 

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Clone + Unpin> Future for Lock<T> where
    Lock<T>: Destruct<T>,
    Guard<T>: Destruct<T>, 

type Output = Guard<T>

The type of value produced on completion.

fn poll(self: Pin<&mut Self>, cx: &mut Context) -> Poll<Self::Output>

Attempt to resolve the future to a final value, registering the current task for wakeup if the value is not yet available.

impl New<Arc<Mutex<HashMap<usize, Arc<(AtomicUsize, AtomicUsize, AtomicSerialWaker)>, RandomState>>>> for Lock<MapType>

fn new(target: usize, map: KeyPool<MapType>) -> Self

Create a Lock instance. This operation might block threads from parking for a while Don't use this function inside tokio context please refer to fnew function to provide asynchrons Lock instance generation