compio-actor 0.1.0

Actors for Compio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21

use std::num::NonZeroUsize;

/// Routing policy used by a process group.
#[derive(Clone, Copy, Debug, Default, PartialEq, Eq)]
pub enum Strategy {
    /// Routes each message to the member after the previous selection.
    #[default]
    RoundRobin,
}

impl Strategy {
    pub(super) fn select(&self, cursor: &mut usize, members: NonZeroUsize) -> usize {
        match self {
            Self::RoundRobin => {
                let selected = *cursor % members.get();
                *cursor = cursor.wrapping_add(1);
                selected
            }
        }
    }
}