A simple, specialized channel type for beaming data out of a newly spawned thread.
First, add threadbeam
to your crate's dependencies in Cargo.toml:
toml
[dependencies]
threadbeam = "0"
```rust let (tx, rx) = threadbeam::channel();
std::thread::spawn(move || { tx.send(String::from("Hello, world!")); });
let hello = rx.recv(); asserteq!(hello.asderef(), Some("Hello, world!")); ```
```rust let (hello, thread) = threadbeam::spawn(move |tx| { tx.send(String::from("Hello, world!")); // your code... String::from("Thread completed!") });
asserteq!(hello.asderef(), Some("Hello, world!")); asserteq!(thread.join().ok().asderef(), 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:
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.
toml
[dependencies]
threadbeam = { version = "0", features = ["no_std"] }