parallel 0.11.3

Command-line CPU load balancer for executing jobs in parallel
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

use std::io::{Stdout, Write};
use itoa;

pub fn total_inputs(stdout: &Stdout, threads: usize, inputs: usize) {
    let mut stdout = stdout.lock();
    let _ = stdout.write(b"parallel: processing ");
    let _ = itoa::write(&mut stdout, inputs);
    let _ = stdout.write(b" inputs on ");
    let _ = itoa::write(&mut stdout, threads);
    let _ = stdout.write(b" threads\n");
}

pub fn processing_task(stdout: &Stdout, job: usize, total: usize, input: &str) {
    let mut stdout = stdout.lock();
    let _ = stdout.write(b"parallel: processing task #");
    let _ = itoa::write(&mut stdout, job);
    let _ = stdout.write(b" of ");
    let _ = itoa::write(&mut stdout, total);
    let _ = stdout.write(b": '");
    let _ = stdout.write(input.as_bytes());
    let _ = stdout.write(b"'\n");
}

pub fn task_complete(stdout: &Stdout, job: usize, total: usize, input: &str) {
    let mut stdout = stdout.lock();
    let _ = stdout.write(b"parallel:  completed task #");
    let _ = itoa::write(&mut stdout, job);
    let _ = stdout.write(b" of ");
    let _ = itoa::write(&mut stdout, total);
    let _ = stdout.write(b": '");
    let _ = stdout.write(input.as_bytes());
    let _ = stdout.write(b"'\n");
}