task_queue 0.0.1

The implementation of the thread pool for Rust
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use super::TaskQueue;

pub trait SpawnPolicy {
    fn get_count(&self, queue: &TaskQueue) -> usize;
}

pub struct StaticSpawnPolicy;

impl StaticSpawnPolicy {
    pub fn new() -> StaticSpawnPolicy {
        StaticSpawnPolicy
    }
}

impl SpawnPolicy for StaticSpawnPolicy {
    fn get_count(&self, queue: &TaskQueue) -> usize {
        queue.max_threads
    }
}