2 releases
0.1.1 | Aug 13, 2022 |
---|---|
0.1.0 | Jun 7, 2022 |
#894 in Concurrency
16KB
307 lines
threadbeam
A simple, specialized channel type for beaming data out of a newly spawned thread.
Usage
First, add threadbeam
to your crate's dependencies in Cargo.toml:
[dependencies]
threadbeam = "0"
Examples
let (tx, rx) = threadbeam::channel();
std::thread::spawn(move || {
tx.send(String::from("Hello, world!"));
});
let hello = rx.recv();
assert_eq!(hello.as_deref(), Some("Hello, world!"));
let (hello, thread) = threadbeam::spawn(move |tx| {
tx.send(String::from("Hello, world!"));
// your code...
String::from("Thread completed!")
});
assert_eq!(hello.as_deref(), Some("Hello, world!"));
assert_eq!(thread.join().ok().as_deref(), Some("Thread completed!"));
parking_lot
To use parking_lot
instead of the standard library's implementations of Condvar
and Mutex
, enable the parking_lot
feature in your Cargo.toml:
[dependencies]
threadbeam = { version = "0", features = ["parking_lot"] }
no_std
via spin
For no_std
environments, enable the no_std
feature in your Cargo.toml:
This will use spin
as the provider of the Mutex
implementation.
[dependencies]
threadbeam = { version = "0", features = ["no_std"] }
Dependencies
~0–5MB