Struct WeightedRoundRobinSelector 

pub struct WeightedRoundRobinSelector<T> { /* private fields */ }

Examples

use concurrent_round_robin::WeightedRoundRobinSelector;
let balancer = Arc::new(WeightedRoundRobinSelector::new(
    vec![("1", 1), ("2", 2)]
));
for _i in 0..100 {
    let arc = balancer.clone();
    std::thread::spawn(move ||{
        println!("{}", arc.select().unwrap().value());
    });
}

Implementations

impl<T> WeightedRoundRobinSelector<T>

pub fn new( elements_with_weight: Vec<(T, usize)>, ) -> WeightedRoundRobinSelector<T>

pub fn close(self) -> Vec<(T, usize)>

pub fn select(&self) -> Option<RefMut<'_, usize, T>>

Trait Implementations

impl<T> Drop for WeightedRoundRobinSelector<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Send for WeightedRoundRobinSelector<T>