subx-cli 1.7.4

AI subtitle processing CLI tool, which automatically matches, renames, and converts subtitle files.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51

//! Load balancer for dynamic adjustment of worker distributions
use std::collections::VecDeque;
use std::time::{Duration, Instant};

/// Balancer that tracks CPU and I/O load history and suggests optimal worker distribution.
#[derive(Debug, Clone)]
pub struct LoadBalancer {
    cpu_load_history: VecDeque<f64>,
    io_load_history: VecDeque<f64>,
    last_balance_time: Instant,
    balance_interval: Duration,
}

impl LoadBalancer {
    /// Create a new load balancer with default settings.
    pub fn new() -> Self {
        Self {
            cpu_load_history: VecDeque::with_capacity(10),
            io_load_history: VecDeque::with_capacity(10),
            last_balance_time: Instant::now(),
            balance_interval: Duration::from_secs(30),
        }
    }

    /// Check if it's time to rebalance according to the interval.
    pub fn should_rebalance(&self) -> bool {
        self.last_balance_time.elapsed() >= self.balance_interval
    }

    /// Calculate optimal distribution of CPU and I/O workers.
    ///
    /// Returns a tuple (cpu_workers, io_workers) indicating suggested new limits.
    pub fn calculate_optimal_distribution(&self) -> (usize, usize) {
        // Default behavior: maintain current distribution
        // Actual balancing logic to be implemented in future extensions.
        (0, 0)
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_load_balancer_defaults() {
        let balancer = LoadBalancer::new();
        assert!(!balancer.should_rebalance());
        let (cpu, io) = balancer.calculate_optimal_distribution();
        assert_eq!((cpu, io), (0, 0));
    }
}