23 releases
0.4.1 | Apr 28, 2025 |
---|---|
0.4.0 | Oct 15, 2024 |
0.3.1 | May 28, 2024 |
0.3.0 | Jan 3, 2024 |
0.1.7 | Oct 20, 2023 |
#130 in Concurrency
4,146 downloads per month
Used in 3 crates
58KB
1K
SLoC
Loole
A safe async/sync multi-producer multi-consumer channel.
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());
}
Why Loole?
- Featureful: Unbounded, bounded and rendezvous channels
- Safe: No unsafe code:
#![forbid(unsafe_code)]
! - Capable: Send and receive operations can be blocking (sync) or non-blocking (async)
- Familiar: Compatible with the Flume's API
- Simple: Minimal dependencies, fast to compile
Usage
To use Loole, place the following line under the [dependencies]
section in your Cargo.toml
:
loole = "0.4.1"
Run Benchmarks
Benchmarks measure throughput, which is the number of messages sent and received per second, for messages of 264 bytes each.
To run benchmarks on your local machine, run the following command:
Prior to executing this command, ensure Node.js is installed.
cargo run --release -p benchmark
The above command will generate and update the benchmark images in the README.md file.
Benchmark Results
Benchmark results on:
OS: Ubuntu Linux 23.10, Kernel: 6.5.0-13
CPU: Intel Core i7-13700K (16/24-core/thread)
MPSC
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
MPMC
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
SPSC
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
License
This project is licensed under the MIT license.