[−][src]Struct futures_util::lock::BiLock
A type of futures-powered synchronization primitive which is a mutex between two possible owners.
This primitive is not as generic as a full-blown mutex but is sufficient for
many use cases where there are only two possible owners of a resource. The
implementation of BiLock
can be more optimized for just the two possible
owners.
Note that it's possible to use this lock through a poll-style interface with
the poll_lock
method but you can also use it as a future with the lock
method that consumes a BiLock
and returns a future that will resolve when
it's locked.
A BiLock
is typically used for "split" operations where data which serves
two purposes wants to be split into two to be worked with separately. For
example a TCP stream could be both a reader and a writer or a framing layer
could be both a stream and a sink for messages. A BiLock
enables splitting
these two and then using each independently in a futures-powered fashion.
Methods
impl<T> BiLock<T>
[src]
impl<T> BiLock<T>
pub fn new(t: T) -> (BiLock<T>, BiLock<T>)
[src]
pub fn new(t: T) -> (BiLock<T>, BiLock<T>)
Creates a new BiLock
protecting the provided data.
Two handles to the lock are returned, and these are the only two handles that will ever be available to the lock. These can then be sent to separate tasks to be managed there.
The data behind the bilock is considered to be pinned, which allows Pin
references to locked data. However, this means that the locked value
will only be available through Pin<&mut T>
(not &mut T
) unless T
is Unpin
.
Similarly, reuniting the lock and extracting the inner value is only
possible when T
is Unpin
.
pub fn poll_lock(&self, lw: &LocalWaker) -> Poll<BiLockGuard<T>>
[src]
pub fn poll_lock(&self, lw: &LocalWaker) -> Poll<BiLockGuard<T>>
Attempt to acquire this lock, returning Pending
if it can't be
acquired.
This function will acquire the lock in a nonblocking fashion, returning
immediately if the lock is already held. If the lock is successfully
acquired then Async::Ready
is returned with a value that represents
the locked value (and can be used to access the protected data). The
lock is unlocked when the returned BiLockGuard
is dropped.
If the lock is already held then this function will return
Async::Pending
. In this case the current task will also be scheduled
to receive a notification when the lock would otherwise become
available.
Panics
This function will panic if called outside the context of a future's task.
pub fn lock(&self) -> BiLockAcquire<T>
[src]
pub fn lock(&self) -> BiLockAcquire<T>
Perform a "blocking lock" of this lock, consuming this lock handle and returning a future to the acquired lock.
This function consumes the BiLock<T>
and returns a sentinel future,
BiLockAcquire<T>
. The returned future will resolve to
BiLockAcquired<T>
which represents a locked lock similarly to
BiLockGuard<T>
.
Note that the returned future will never resolve to an error.
pub fn reunite(self, other: Self) -> Result<T, ReuniteError<T>> where
T: Unpin,
[src]
pub fn reunite(self, other: Self) -> Result<T, ReuniteError<T>> where
T: Unpin,
Attempts to put the two "halves" of a BiLock<T>
back together and
recover the original value. Succeeds only if the two BiLock<T>
s
originated from the same call to BiLock::new
.
Trait Implementations
Auto Trait Implementations
Blanket Implementations
impl<T, U> Into for T where
U: From<T>,
[src]
impl<T, U> Into for T where
U: From<T>,
impl<T> From for T
[src]
impl<T> From for T
impl<T, U> TryFrom for T where
T: From<U>,
[src]
impl<T, U> TryFrom for T where
T: From<U>,
type Error = !
try_from
)The type returned in the event of a conversion error.
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
[src]
fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>
try_from
)Performs the conversion.
impl<T> Borrow for T where
T: ?Sized,
[src]
impl<T> Borrow for T where
T: ?Sized,
ⓘImportant traits for &'_ mut Ifn borrow(&self) -> &T
[src]
fn borrow(&self) -> &T
Immutably borrows from an owned value. Read more
impl<T> Any for T where
T: 'static + ?Sized,
[src]
impl<T> Any for T where
T: 'static + ?Sized,
fn get_type_id(&self) -> TypeId
[src]
fn get_type_id(&self) -> TypeId
🔬 This is a nightly-only experimental API. (get_type_id
)
this method will likely be replaced by an associated static
Gets the TypeId
of self
. Read more
impl<T> BorrowMut for T where
T: ?Sized,
[src]
impl<T> BorrowMut for T where
T: ?Sized,
ⓘImportant traits for &'_ mut Ifn borrow_mut(&mut self) -> &mut T
[src]
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
impl<T, U> TryInto for T where
U: TryFrom<T>,
[src]
impl<T, U> TryInto for T where
U: TryFrom<T>,