cpu-worker: clear tasks on shutdown

src/cpu_worker.rs

@@ -200,6 +200,15 @@ impl Drop for PendingJob {
 }
 
 impl CpuWorkerData {
+    fn clear(&self) {
+        self.jobs_to_enqueue.clear();
+        self.new_jobs.lock().clear();
+        self.completed_jobs_remote.lock().queue.clear();
+        self.completed_jobs_local.borrow_mut().clear();
+        self.pending_jobs.clear();
+        self.pending_job_data_cache.take();
+    }
+
     async fn wait_for_completions(self: Rc<Self>) {
         let mut buf = TypedBuf::<u64>::new();
         loop {
@@ -302,6 +311,10 @@ impl CpuWorker {
         })
     }
 
+    pub fn clear(&self) {
+        self.data.clear();
+    }
+
     pub fn submit(&self, job: Box<dyn CpuJob>) -> PendingJob {
         let mut job = NonNull::from(Box::leak(job));
         let id = self.data.next.next();