parallel-processor 0.2.3

Framework to manage asynchronous execution of multiple compute units communicating using messages
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

#![cfg_attr(debug_assertions, deny(warnings))]

#[macro_use]
pub extern crate mt_debug_counters;

pub use mt_debug_counters::logging::enable_counters_logging;

pub const DEFAULT_BINCODE_CONFIG: bincode::config::Configuration = bincode::config::standard();

#[macro_use]
pub mod memory_fs;
pub mod buckets;
pub mod debug_allocator;
pub mod execution_manager;
pub mod fast_smart_bucket_sort;
#[macro_use]
mod logging;
pub mod memory_data_size;
pub mod phase_times_monitor;
pub mod utils;

pub use logging::{set_logger_function, LogLevel};

#[cfg(target_os = "linux")]
pub mod simple_process_stats;

pub struct Utils {}

impl Utils {
    pub fn multiply_by(val: usize, mult: f64) -> usize {
        ((val as f64) * mult) as usize
    }
}