Struct aqueue::AQueue

pub struct AQueue { /* private fields */ }

async future thread safe queue

Implementations

impl AQueue

pub fn new() -> AQueue

pub fn sync_run<A, R>(&self, call: impl FnOnce(A) -> R, arg: A) -> R

Sync run fn Note: it is not based on fair lock. It will never be called when the queue has unprocessed

pub async fn run<A, T, R>(&self, call: impl FnOnce(A) -> T, arg: A) -> Rwhere T: Future<Output = R>,

Async run fn It is based on the principle of first in, first run

Trait Implementations

impl Default for AQueue

fn default() -> Self

Returns the “default value” for a type.