itsscb/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2025-10-01 12:20:39 +00:00
Code Issues Packages Projects Releases Wiki Activity

metrics: removed race condition from global_queue_depth_multi_thread test (#6936)

Browse Source
This commit is contained in:
Jonas Fassbender 2024-10-27 19:36:18 +01:00 committed by GitHub
parent 946401c345
commit 070a825999
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
tokio/tests/rt_metrics.rs
View File

@ -66,10 +66,10 @@ fn global_queue_depth_current_thread() {
#[test] #[test]
fn global_queue_depth_multi_thread() { fn global_queue_depth_multi_thread() {
for _ in 0..10 {
let rt = threaded(); let rt = threaded();
let metrics = rt.metrics(); let metrics = rt.metrics();
for _ in 0..10 {
if let Ok(_blocking_tasks) = try_block_threaded(&rt) { if let Ok(_blocking_tasks) = try_block_threaded(&rt) {
for i in 0..10 { for i in 0..10 {
assert_eq!(i, metrics.global_queue_depth()); assert_eq!(i, metrics.global_queue_depth());
@ -93,7 +93,7 @@ fn try_block_threaded(rt: &Runtime) -> Result<Vec<mpsc::Sender<()>>, mpsc::RecvT
// Spawn a task per runtime worker to block it. // Spawn a task per runtime worker to block it.
rt.spawn(async move { rt.spawn(async move {
tx.send(()).unwrap(); tx.send(()).ok();
barrier.recv().ok(); barrier.recv().ok();
}); });