mirror of
https://github.com/tokio-rs/tokio.git
synced 2025-09-28 12:10:37 +00:00
5a5dde70b3
* Minimize allocation needed for channels * Use a newtype for signal ids * We can just cast the raw pointer to a `usize` and still perform a simple identity check, without incurring any implications of storing a raw pointer (e.g. previously Signal was !Sync and had an unsafe impl of Send, and now it is naturally Sync+Send) * Broadcast with `try_send` instead of `start_send` The `Stream::start_send` method uses backpressure and schedules the current task to be notified whenever the channel has additional room, which means we'll generate a lot of unnecessary wakeups whenever a channel gets full By changing to `try_send` and handling any errors, we ensure the Driver's task won't get woken up when a Signal finally consumes its notification, since we're coalescing things anyway
tokio-signal
An implementation of Unix signal handling for Tokio
Usage
First, add this to your Cargo.toml:
[dependencies]
tokio-signal = "0.2"
Next you can use this in conjunction with the tokio and futures crates:
extern crate futures;
extern crate tokio;
extern crate tokio_signal;
use futures::{Future, Stream};
fn main() {
// Create an infinite stream of "Ctrl+C" notifications. Each item received
// on this stream may represent multiple ctrl-c signals.
let ctrl_c = tokio_signal::ctrl_c().flatten_stream();
// Process each ctrl-c as it comes in
let prog = ctrl_c.for_each(|()| {
println!("ctrl-c received!");
Ok(())
});
tokio::run(prog.map_err(|err| panic!("{}", err)));
}
License
This project is licensed the MIT license (LICENSE or http://opensource.org/licenses/MIT).
Contribution
Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in Tokio by you, shall be licensed as MIT, without any additional terms or conditions.