use itertools::{Either, Itertools};
use rand::Rng;
#[derive(Debug, Clone)]
pub struct WeightedPicker<T> {
prob: Vec<f64>,
alias: Vec<usize>,
items: Vec<T>,
}
impl<T> WeightedPicker<T> {
pub fn new(entries: Vec<(T, f64)>) -> Self {
assert_ne!(entries.len(), 0, "Cannot use an empty vec!");
let total_weight: f64 = entries.iter().map(|(_, weight)| *weight).sum();
let len = entries.len();
let average = (len as f64).recip();
let (items, weights): (Vec<_>, Vec<_>) = entries.into_iter().unzip();
let (mut small, mut large): (Vec<_>, Vec<_>) = weights
.iter()
.enumerate()
.map(|(idx, weight)| {
let prob = weight / total_weight * len as f64;
(idx, prob)
})
.partition_map(|(idx, prob)| {
if prob < average {
Either::Left(idx)
} else {
Either::Right(idx)
}
});
let mut alias = vec![0; len];
let mut prob = vec![0.0; len];
while !small.is_empty() && !large.is_empty() {
let less = small.pop().unwrap();
let more = large.pop().unwrap();
prob[less] *= len as f64;
alias[less] = more;
let prev_more = prob[more];
let prev_less = prob[less];
prob[more] = prev_more + prev_less - average;
if prob[more] >= average {
large.push(more)
} else {
small.push(more);
}
}
while let Some(last) = small.pop() {
prob[last] = 1.0;
}
while let Some(last) = large.pop() {
prob[last] = 1.0;
}
debug_assert_eq!(prob.len(), len);
debug_assert_eq!(alias.len(), len);
debug_assert_eq!(items.len(), len);
Self { alias, items, prob }
}
pub fn get<R: Rng + ?Sized>(&self, rng: &mut R) -> &T {
&self.items[self.get_idx(rng)]
}
pub fn get_idx<R: Rng + ?Sized>(&self, rng: &mut R) -> usize {
let column = rng.gen_range(0..self.prob.len());
let coin_toss = rng.gen::<f64>() < self.prob[column];
if coin_toss {
column
} else {
self.alias[column]
}
}
pub fn get_by_idx(&self, idx: usize) -> Option<&T> {
self.items.get(idx)
}
pub fn get_mut_by_idx(&mut self, idx: usize) -> Option<&mut T> {
self.items.get_mut(idx)
}
pub fn pick<R: Rng + ?Sized>(items: Vec<(T, f64)>, rng: &mut R) -> T {
let mut wp = WeightedPicker::new(items);
let idx = wp.get_idx(rng);
wp.items.remove(idx)
}
}
#[test]
fn pick() {
let picker = WeightedPicker::new(vec![
("common", 10.0),
("uncommon", 5.0),
("rare", 2.0),
("legendary", 1.0),
("mythic", 0.1),
]);
let mut rng = rand::thread_rng();
for _ in 0..10 {
println!("- {}", picker.get(&mut rng));
}
}