(&'static self, func: F)
| 402 | // Terminate and wake the workers. |
| 403 | let member_data = self.get_member_data(); |
| 404 | for worker in &terminating_workers { |
| 405 | // Tell the worker to halt. |
| 406 | worker.control.halt.store(true, Ordering::Relaxed); |
| 407 | // Signal the worker. |
| 408 | member_data.semaphores[worker.member_index].signal(); |
| 409 | } |
| 410 | |
| 411 | // Drop the lock on the state so as not to block the workers or |
| 412 | // heartbeat. |
| 413 | drop(managed_workers); |
no test coverage detected