Loole

A safe async/sync multi-producer multi-consumer channel.

Producers can send and consumers can receive messages asynchronously or synchronously:

• sync -> sync
• async -> async
• sync -> async
• async -> sync

fn main() {
    let (tx, rx) = loole::unbounded();

    std::thread::spawn(move || {
        for i in 0..10 {
            tx.send(i).unwrap();
        }
    });

    let mut sum = 0;
    while let Ok(i) = rx.recv() {
        sum += i;
    }

    assert_eq!(sum, (0..10).sum());
}

Usage

To use Loole, place the following line under the [dependencies] section in your Cargo.toml:

loole = "0.1.7"

Benchmarks

Benchmarks measure throughput, which is the number of messages sent and received per second, for messages of 264 bytes each.

Run benchmarks

To run benchmarks on your local machine, run the following command:

cargo run --release -p benchmark

The above command will generate and update the benchmark images in the README.md file.

MPSC

Measures: Messages per seconds. (higher is better)

Messages size: 264 bytes.

MPMC

Measures: Messages per seconds. (higher is better)

Messages size: 264 bytes.

SPSC

Measures: Messages per seconds. (higher is better)

Messages size: 264 bytes.

License

Loole is licensed under either of:

• Apache License 2.0, (http://www.apache.org/licenses/LICENSE-2.0)

• MIT license (http://opensource.org/licenses/MIT)