Skip to content

Commit 5b9c503

Browse files
authored
refactor: pop tasks before whole runtime shutdown (#208)
1 parent 716a9a3 commit 5b9c503

File tree

1 file changed

+9
-0
lines changed

1 file changed

+9
-0
lines changed

monoio/src/scheduler.rs

+9
Original file line numberDiff line numberDiff line change
@@ -27,6 +27,15 @@ impl Default for TaskQueue {
2727
}
2828
}
2929

30+
impl Drop for TaskQueue {
31+
fn drop(&mut self) {
32+
unsafe {
33+
let queue = &mut *self.queue.get();
34+
while let Some(_task) = queue.pop_front() {}
35+
}
36+
}
37+
}
38+
3039
impl TaskQueue {
3140
pub(crate) fn new() -> Self {
3241
const DEFAULT_TASK_QUEUE_SIZE: usize = 4096;

0 commit comments

Comments
 (0)