Crate ice_threads

ice-threads

ice-threads is a lightweight Thread Pool (Melter) implementation.

User can enqueue Tasks (Ice) to be executed.

Optionally, user can return a value that can be collected through a special handle (Bottle) that is returned by the thread pool task enqueuing method.

Tasks are put into the queue and eventually picked up by a task stealing thread (Heater) and executed.

Features

• Very simple to use. Examples.
• Very light crate with no dependencies.

Examples

Bare minimum:

use ice_threads::Melter;

fn main() {
    let melter = Melter::new(1);

    let s = melter.melt(|| {
        "Watch this task melt away!"
    }).open();

    println!("{}", s);
}

Full control over result collection method:

use ice_threads::Melter;

fn main() {
    let melter = Melter::new(4);
    let mut bottles = Vec::new();

    let src = "Water is collected synchronously in whatever order you want it to be";
    for chr in src.chars() {
        bottles.push(melter.melt(
            move || {
                chr
            }
        ));
    }

    let water = bottles.iter()
                        .map(|bottle| { bottle.open() })
                        .collect::<String>();

    println!("{}", water);
}

More thorough example:

use ice_threads::Melter;


fn main() {
    let melter = Melter::new(4);
    let mut bottles = Vec::new(); // Vec<Bottle<i32>>

    for task_id in 0..8i32 { // add a type hint for Rust
        // Handle must always be used...
        let bottle = melter.melt(move || {
            use std::{thread::sleep, time::Duration};

            // time consuming task
            sleep(Duration::from_secs(1));

            println!("Finished task {}", task_id);

            task_id
        });

        // ...and not dropped without using it first
        bottles.push(bottle);
    }

    // results don't need to be used but bottles must be opened
    for bottle in bottles {
        let result = bottle.open(); // blocking operation
        println!("Opened bottle, got: {}", result);
    }
}

Changelog

v0.1.0

• Introduced Melter type (Thread Pool)
• Introduced Bottle type ("Future")

Structs

Bottle	Water Bottle.
Melter	Ice Melter.