Struct deno_core::TaskQueue

pub struct TaskQueue { /* private fields */ }

A queue that executes tasks sequentially one after the other ensuring order and that no task runs at the same time as another.

Note that tokio’s semaphore doesn’t seem to maintain order and so we can’t use that in the code that uses this or use that here.

Implementations

impl TaskQueue

pub async fn acquire(&self) -> TaskQueuePermit<'_>

Acquires a permit where the tasks are executed one at a time and in the order that they were acquired.

pub async fn queue<R>(&self, future: impl Future<Output = R>) -> R

Alternate API that acquires a permit internally for the duration of the future.

Trait Implementations

impl Debug for TaskQueue

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

Formats the value using the given formatter.

impl Default for TaskQueue

fn default() -> TaskQueue

Returns the “default value” for a type.