Struct async_wrr_queue::WrrQueue

pub struct WrrQueue<T: PartialEq> { /* private fields */ }

weighted round robin queue struct

WRR queue, each time new instance is inserted, balance queue need to be recalculated. So minimizing the insert operation can improve performance.

select method requires only an atomic usize and a Read access to the RwLock. There should be of no runtime performance issue.

example:

use async_wrr_queue::{WrrQueue, Instance};
use std::num::NonZeroUsize;

let mut queue = WrrQueue::new().insert_many([("data1", 1), ("data2", 2), ("data3", 3)]).await;
queue.insert(Instance::new_with_weight("data4", NonZeroUsize::new(4).unwrap())).await;

let selected1 = queue.select();
let selected2 = queue.select();
let selected3 = queue.select();

Implementations

impl<T: PartialEq> WrrQueue<T>

pub fn new() -> Self

impl<T: PartialEq> WrrQueue<T>

pub async fn insert(&mut self, instance: impl Into<Instance<T>>) -> bool

insert a new instance, and re-calculate request queue

pub async fn insert_many<U>(&mut self, instance_list: impl Into<Vec<U>>) -> bool

where T: PartialEq, U: Into<Instance<T>>,

insert a new instance vec, and re-calculate request queue recommended when have multiple instance to be inserted

pub async fn select(&mut self) -> Option<&Instance<T>>

return the selected instance, None if instance_list is empty NOTE: select operation used only atomic operation, and can be paralleled

Trait Implementations

impl<T: PartialEq> Default for WrrQueue<T>

fn default() -> Self

create a default WRR Queue, with no data