branch comparison

src/bastion-executor/src/run.rs

@@ -59,10 +59,6 @@ where
             Pin<&'static mut dyn Future<Output = ()>>,
         >(future);
 
-        // Unpark a thread to make sure
-        // we'll be able to drive this to completion asap.
-        worker::load_balancer().unpark_thread();
-
         // Block on the future and and wait for it to complete.
         worker::set_stack(&stack, || block(future));
 

src/bastion-executor/src/worker.rs

@@ -78,6 +78,9 @@ pub(crate) fn schedule(proc: LightProc) {
     });
 
     pool::get().sleepers.notify_one();
+    // Unpark threads to make sure
+    // we'll be able to drive this to completion asap.
+    worker::load_balancer().unpark_thread();
 }
 
 ///

src/bastion/Cargo.toml

@@ -50,7 +50,7 @@ features = ["docs"]
 rustdoc-args = ["--cfg", "feature=\"docs\""]
 
 [dependencies]
-bastion-executor = { git = "https://github.com/bastion-rs/bastion", branch = "igni/affine_steal_sort" } # "0.3.6"
+bastion-executor = { git = "https://github.com/bastion-rs/bastion", branch = "igni/unpark_on_schedule" } # "0.3.6"
 lightproc = "0.3.5"
 # bastion-executor = { version = "= 0.3.7-alpha.0", path = "../bastion-executor" }
 # lightproc = { version = "= 0.3.6-alpha.0", path = "../lightproc" }