We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 59b2dd2 commit 415f91bCopy full SHA for 415f91b
crates/bevy_tasks/src/task_pool.rs
@@ -2,8 +2,9 @@ use std::{
2
future::Future,
3
marker::PhantomData,
4
mem,
5
+ pin::Pin,
6
sync::Arc,
- thread::{self, JoinHandle}, pin::Pin,
7
+ thread::{self, JoinHandle},
8
};
9
10
use concurrent_queue::ConcurrentQueue;
@@ -264,7 +265,7 @@ impl TaskPool {
264
265
results
266
267
- // Pin the futures on the stack.
268
+ // Pin the futures on the stack.
269
pin!(get_results);
270
271
// SAFETY: This function blocks until all futures complete, so we do not read/write
@@ -286,7 +287,7 @@ impl TaskPool {
286
287
if let Some(result) = future::block_on(future::poll_once(&mut spawned)) {
288
break result;
289
-
290
+
291
self.executor.try_tick();
292
task_scope_executor.try_tick();
293
}
0 commit comments