Module tokio_util::sync

Synchronization primitives

Modules

• cancellation_token 🔒
  An asynchronously awaitable CancellationToken. The token allows to signal a cancellation request to one or more tasks.
• mpsc 🔒
• poll_semaphore 🔒
• reusable_box 🔒

Structs

• CancellationToken
  A token which can be used to signal a cancellation request to one or more tasks.
• DropGuard
  A wrapper for cancellation token which automatically cancels it on drop. It is created using drop_guard method on the CancellationToken.
• PollSemaphore
  A wrapper around Semaphore that provides a poll_acquire method.
• PollSendError
  Error returned by the PollSender when the channel is closed.
• PollSender
  A wrapper around mpsc::Sender that can be polled.
• ReusableBoxFuture
  A reusable Pin<Box<dyn Future<Output = T> + Send + 'a>>.
• WaitForCancellationFuture
  A Future that is resolved once the corresponding CancellationToken is cancelled.
• WaitForCancellationFutureOwned
  A Future that is resolved once the corresponding CancellationToken is cancelled.