use step_or_park(None) in shutdown
@@ -84,7 +84,7 @@ where
let alloc = crate::communication::allocator::thread::Thread::new();
let mut worker = crate::worker::Worker::new(alloc);
let result = func(&mut worker);
- while worker.step() { }
+ while worker.step_or_park() { }
result
}
@@ -199,7 +199,7 @@ where
}
let result = func(&mut worker);
- while worker.step() { }
+ while worker.step_or_park(None) { }
result
})
}
@@ -284,7 +284,7 @@ where
initialize_from(builders, others, move |allocator| {
let mut worker = Worker::new(allocator);
let result = func(&mut worker);
- while worker.step() { }
+ while worker.step_or_park(None) { }
result
})
}
\ No newline at end of file
