A safe sync/async multi-producer, multi-consumer channel
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());
}
To use Loole, place the following line under the [dependencies]
section in your Cargo.toml
:
loole = "0.1.7"
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 on Intel Core i7-13700K (16/24-core/thread) processor:
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
Measures: Messages per second. (higher is better)
Messages size: 264 bytes.
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)