| 498 | } |
| 499 | |
| 500 | void DoSpawnAdds(ThreadPool* pool, int nadds, AddTaskFunc add_func, |
| 501 | StopToken stop_token = StopToken::Unstoppable(), |
| 502 | StopSource* stop_source = nullptr) { |
| 503 | AddTester add_tester(nadds, stop_token); |
| 504 | add_tester.SpawnTasks(pool, add_func); |
| 505 | if (stop_source) { |
| 506 | stop_source->RequestStop(); |
| 507 | } |
| 508 | ASSERT_OK(pool->Shutdown()); |
| 509 | if (stop_source) { |
| 510 | add_tester.CheckNotAllComputed(); |
| 511 | } else { |
| 512 | add_tester.CheckResults(); |
| 513 | } |
| 514 | } |
| 515 | |
| 516 | void SpawnAdds(ThreadPool* pool, int nadds, AddTaskFunc add_func, |
| 517 | StopToken stop_token = StopToken::Unstoppable()) { |
nothing calls this directly
no test coverage detected