fix OwnedTasks::new() call

tokio-rs · Sep 12, 2023 · f8a5f10 · f8a5f10
1 parent 5ffbf01
commit f8a5f10
Show file tree

Hide file tree

Showing 3 changed files with 2 additions and 2 deletions.
diff --git a/.DS_Store b/.DS_Store
diff --git a/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs b/tokio/src/runtime/scheduler/multi_thread_alt/worker.rs
@@ -307,7 +307,7 @@ pub(super) fn create(
             remotes: remotes.into_boxed_slice(),
             inject,
             idle,
-            owned: OwnedTasks::new(),
+            owned: OwnedTasks::new(16),
             synced: Mutex::new(Synced {
                 assigned_cores: (0..num_workers).map(|_| None).collect(),
                 shutdown_cores: Vec::with_capacity(num_cores),

diff --git a/tokio/src/runtime/tests/task.rs b/tokio/src/runtime/tests/task.rs
@@ -241,7 +241,7 @@ fn with(f: impl FnOnce(Runtime)) {
     let _reset = Reset;
 
     let rt = Runtime(Arc::new(Inner {
-        owned: OwnedTasks::new(),
+        owned: OwnedTasks::new(16),
         core: Mutex::new(Core {
             queue: VecDeque::new(),
         }),