fix iterate in close_and_shutdown

tokio-rs · Sep 13, 2023 · 9bfb4f1 · 9bfb4f1
1 parent 6453017
commit 9bfb4f1
Showing 1 changed file with 1 addition and 6 deletions.
diff --git a/tokio/src/runtime/task/list.rs b/tokio/src/runtime/task/list.rs
@@ -154,15 +154,10 @@ impl<S: 'static> OwnedTasks<S> {
         self.closed.fetch_and(true, Ordering::Release);
 
         for i in 0..self.lists.len() {
-            let first_task = self.pop_back_inner(i);
-            match first_task {
-                Some(task) => task.shutdown(),
-                None => return,
-            }
             loop {
                 let task = match self.pop_back_inner(i) {
                     Some(task) => task,
-                    None => return,
+                    None => continue,
                 };
                 task.shutdown();
             }