diff options
Diffstat (limited to 'tokio/tests/signal_multi_rt.rs')
-rw-r--r-- | tokio/tests/signal_multi_rt.rs | 47 |
1 files changed, 47 insertions, 0 deletions
diff --git a/tokio/tests/signal_multi_rt.rs b/tokio/tests/signal_multi_rt.rs new file mode 100644 index 00000000..9ecf70ed --- /dev/null +++ b/tokio/tests/signal_multi_rt.rs @@ -0,0 +1,47 @@ +#![cfg(unix)] +#![warn(rust_2018_idioms)] + +mod support { + pub mod signal; +} +use support::signal::send_signal; + +use tokio::prelude::*; +use tokio::runtime::current_thread::Runtime; +use tokio::signal::unix::{signal, SignalKind}; + +use std::sync::mpsc::channel; +use std::thread; + +#[test] +fn multi_loop() { + // An "ordinary" (non-future) channel + let (sender, receiver) = channel(); + // Run multiple times, to make sure there are no race conditions + for _ in 0..10 { + // Run multiple event loops, each one in its own thread + let threads: Vec<_> = (0..4) + .map(|_| { + let sender = sender.clone(); + thread::spawn(move || { + let mut rt = Runtime::new().unwrap(); + let _ = rt.block_on(async { + let signal = signal(SignalKind::hangup()).unwrap(); + sender.send(()).unwrap(); + signal.into_future().await + }); + }) + }) + .collect(); + // Wait for them to declare they're ready + for &_ in threads.iter() { + receiver.recv().unwrap(); + } + // Send a signal + send_signal(libc::SIGHUP); + // Make sure the threads terminated correctly + for t in threads { + t.join().unwrap(); + } + } +} |