fluxus-core 0.2.0

Core components for Fluxus stream processing engine
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

/// Configuration for parallel processing
#[derive(Debug, Clone)]
pub struct ParallelConfig {
    /// Number of parallel tasks
    pub parallelism: usize,
    /// Maximum buffer size per task
    pub buffer_size: usize,
    /// Whether to preserve ordering in parallel processing
    pub preserve_order: bool,
}

impl Default for ParallelConfig {
    fn default() -> Self {
        Self {
            parallelism: num_cpus::get(),
            buffer_size: 1000,
            preserve_order: true,
        }
    }
}

impl ParallelConfig {
    /// Create a new parallel configuration
    pub fn new(parallelism: usize, buffer_size: usize, preserve_order: bool) -> Self {
        Self {
            parallelism,
            buffer_size,
            preserve_order,
        }
    }

    /// Set the number of parallel tasks
    pub fn with_parallelism(mut self, parallelism: usize) -> Self {
        self.parallelism = parallelism;
        self
    }

    /// Set the buffer size per task
    pub fn with_buffer_size(mut self, buffer_size: usize) -> Self {
        self.buffer_size = buffer_size;
        self
    }

    /// Set whether to preserve ordering
    pub fn with_preserve_order(mut self, preserve_order: bool) -> Self {
        self.preserve_order = preserve_order;
        self
    }
}