File tree 1 file changed +9
-9
lines changed
1 file changed +9
-9
lines changed Original file line number Diff line number Diff line change @@ -227,14 +227,11 @@ impl<'a> Executor<'a> {
227
227
let state = self . state ( ) ;
228
228
let runnable = state
229
229
. tick_with ( |local, steal| {
230
- local. queue . pop ( ) . ok ( )
231
- . or_else ( || {
232
- if steal {
233
- state. queue . pop ( ) . ok ( )
234
- } else {
235
- None
236
- }
237
- } )
230
+ local
231
+ . queue
232
+ . pop ( )
233
+ . ok ( )
234
+ . or_else ( || if steal { state. queue . pop ( ) . ok ( ) } else { None } )
238
235
} )
239
236
. await ;
240
237
runnable. run ( ) ;
@@ -577,7 +574,10 @@ impl State {
577
574
}
578
575
579
576
/// Run a tick using the provided function to get the next task.
580
- async fn tick_with ( & self , mut local_ticker : impl FnMut ( & LocalQueue , bool ) -> Option < Runnable > ) -> Runnable {
577
+ async fn tick_with (
578
+ & self ,
579
+ mut local_ticker : impl FnMut ( & LocalQueue , bool ) -> Option < Runnable > ,
580
+ ) -> Runnable {
581
581
let local = self . local_queue . get_or_default ( ) ;
582
582
583
583
loop {
You can’t perform that action at this time.
0 commit comments