Skip to content

Commit 40cf00a

Browse files
committed
Test mpmc's current_thread_id()
1 parent 400fabe commit 40cf00a

File tree

2 files changed

+16
-0
lines changed

2 files changed

+16
-0
lines changed

library/std/src/sync/mpmc/mod.rs

+3
Original file line numberDiff line numberDiff line change
@@ -1382,3 +1382,6 @@ impl<T> fmt::Debug for Receiver<T> {
13821382
f.pad("Receiver { .. }")
13831383
}
13841384
}
1385+
1386+
#[cfg(test)]
1387+
mod tests;

library/std/src/sync/mpmc/tests.rs

+13
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,13 @@
1+
#[test]
2+
fn waker_current_thread_id() {
3+
let first = super::waker::current_thread_id();
4+
let t = crate::thread::spawn(|| {
5+
let second = super::waker::current_thread_id();
6+
assert_ne!(first, second);
7+
assert_eq!(second, super::waker::current_thread_id());
8+
});
9+
10+
assert_eq!(first, super::waker::current_thread_id());
11+
t.join().unwrap();
12+
assert_eq!(first, super::waker::current_thread_id());
13+
}

0 commit comments

Comments
 (0)