(&'static self, func: F)
| 368 | // Calculate the new size of the pool (counting only managed workers). |
| 369 | let new_size = get_size(current_size); |
| 370 | |
| 371 | match new_size.cmp(¤t_size) { |
| 372 | // The size remained the same |
| 373 | cmp::Ordering::Equal => current_size, |
| 374 | // The size increased |
| 375 | cmp::Ordering::Greater => { |
| 376 | // Spawn the new workers. |
| 377 | let memberships = self.try_enroll_many(new_size - current_size); |
| 378 | for membership in memberships { |
| 379 | let member_index = membership.member_index; |
| 380 | let halt = Arc::new(AtomicBool::new(false)); |
| 381 | let worker_halt = halt.clone(); |
| 382 | let handle = ThreadBuilder::new() |
| 383 | .name(format!("managed worker {member_index}")) |
no test coverage detected