tokio-rs/tokio
1
0
Fork 0
mirror of https://github.com/tokio-rs/tokio.git synced 2026-08-29 00:00:11 +02:00
Code Issues Packages Projects Releases Wiki Activity

metrics: fix hang in worker_overflow_count test (#6146)

Browse Source 
Closes: #6054
This commit is contained in:
Alice Ryhl
2023-11-14 20:13:56 +01:00
committed by GitHub
parent d44e995bb0
commit e6720f985d
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
tokio/tests/rt_metrics.rs
+9 -6
View File
@@ -471,14 +471,17 @@ fn worker_overflow_count() {
// First, we need to block the other worker until all tasks have // First, we need to block the other worker until all tasks have
// been spawned. // been spawned.
tokio::spawn(async move { //
tx1.send(()).unwrap(); // We spawn from outside the runtime to ensure that the other worker
rx2.recv().unwrap(); // will pick it up:
// <https://github.com/tokio-rs/tokio/issues/4730>
tokio::task::spawn_blocking(|| {
tokio::spawn(async move {
tx1.send(()).unwrap();
rx2.recv().unwrap();
});
}); });
// Bump the next-run spawn
tokio::spawn(async {});
rx1.recv().unwrap(); rx1.recv().unwrap();
// Spawn many tasks // Spawn many tasks