(&self, worker: PendingWorkerHandle)
| 232 | } |
| 233 | |
| 234 | fn add_pending_worker(&self, worker: PendingWorkerHandle) { |
| 235 | let mut w = self.inner.lock().unwrap(); |
| 236 | w.pending_starts.insert(worker.worker_id, worker); |
| 237 | } |
| 238 | |
| 239 | fn gen_id(&self) -> u64 { |
| 240 | let mut inner = self.inner.lock().unwrap(); |