Struct InternalSlowJobPool 

struct InternalSlowJobPool {
    next_id: u64,
    queue: HashMap<String, VecDeque<Queue>>,
    configs: HashMap<String, Config>,
    last_spawned_configs: Vec<String>,
    global_spawned_and_running: u64,
    global_limit: u64,
    jobs_metrics_cnt: usize,
    jobs_metrics: HashMap<String, Vec<JobMetrics>>,
    threadpool: Arc<ThreadPool>,
    internal: Option<Arc<Mutex<Self>>>,
}

Fields

next_id: u64

queue: HashMap<String, VecDeque<Queue>>

configs: HashMap<String, Config>

last_spawned_configs: Vec<String>

global_spawned_and_running: u64

global_limit: u64

jobs_metrics_cnt: usize

jobs_metrics: HashMap<String, Vec<JobMetrics>>

threadpool: Arc<ThreadPool>

internal: Option<Arc<Mutex<Self>>>

Implementations

impl InternalSlowJobPool

pub fn new( global_limit: u64, jobs_metrics_cnt: usize, _threadpool: Arc<ThreadPool>, ) -> Arc<Mutex<Self>>

fn calc_queued_order( &self, queued: HashMap<&String, u64>, limit: usize, ) -> Vec<String>

returns order of configuration which are queued next

fn can_spawn(&self, name: &str) -> bool

pub fn spawn<F>(&mut self, name: &str, f: F) -> SlowJob

where F: FnOnce() + Send + Sync + 'static,

fn finish(&mut self, name: &str, metrics: JobMetrics)

fn spawn_queued(&mut self)

pub fn take_metrics(&mut self) -> HashMap<String, Vec<JobMetrics>>