#non-blocking #asynchronous #async

nbchan

Highly optimized non-blocking communication channels

4 releases

Uses old Rust 2015

0.1.3 Jul 21, 2018
0.1.2 Jan 6, 2018
0.1.1 Jan 6, 2018
0.1.0 May 7, 2017

#435 in Concurrency

Download history 253/week @ 2023-08-13 148/week @ 2023-08-20 117/week @ 2023-08-27 220/week @ 2023-09-03 191/week @ 2023-09-10 163/week @ 2023-09-17 149/week @ 2023-09-24 166/week @ 2023-10-01 149/week @ 2023-10-08 199/week @ 2023-10-15 240/week @ 2023-10-22 196/week @ 2023-10-29 234/week @ 2023-11-05 216/week @ 2023-11-12 220/week @ 2023-11-19 192/week @ 2023-11-26

889 downloads per month
Used in 32 crates (via fibers)

MIT license

22KB
499 lines

nbchan

Crates.io: nbchan Documentation Build Status Code Coverage License: MIT

Highly optimized non-blocking communication channels implemented in Rust.

Documentation

Informal Benchmarks

The version of nbchan is v0.1.0:

$ cat /etc/lsb-release | tail -1
DISTRIB_DESCRIPTION="Ubuntu 17.04"

$ cat /proc/cpuinfo | grep 'model name'
model name      : Intel(R) Core(TM) i7-6600U CPU @ 2.60GHz
model name      : Intel(R) Core(TM) i7-6600U CPU @ 2.60GHz
model name      : Intel(R) Core(TM) i7-6600U CPU @ 2.60GHz
model name      : Intel(R) Core(TM) i7-6600U CPU @ 2.60GHz

$ rustup run nightly rustc -V
rustc 1.18.0-nightly (036983201 2017-04-26)

$ rustup run nightly cargo bench
running 8 tests
test create_nbchan_oneshot                ... bench:          23 ns/iter (+/- 1)
test create_std_mpsc                      ... bench:          64 ns/iter (+/- 6)
test failure_send_nbchan_oneshot          ... bench:          40 ns/iter (+/- 1)
test failure_send_std_mpsc                ... bench:          85 ns/iter (+/- 6)
test multithread_send_recv_nbchan_oneshot ... bench:          71 ns/iter (+/- 19)
test multithread_send_recv_std_mpsc       ... bench:         108 ns/iter (+/- 53)
test send_recv_nbchan_oneshot             ... bench:          35 ns/iter (+/- 4)
test send_recv_std_mpsc                   ... bench:          82 ns/iter (+/- 3)

test result: ok. 0 passed; 0 failed; 0 ignored; 8 measured
$ cargo run --example channel_size
nbchan::oneshot::Sender<()>:   8 bytes
nbchan::oneshot::Receiver<()>: 8 bytes
std::sync::mpsc::Sender<()>:   16 bytes
std::sync::mpsc::Receiver<()>: 16 bytes

No runtime deps