| 294 | } |
| 295 | |
| 296 | bool Consumer::IsAllTaskFinish() { |
| 297 | if (impl_->nhandle_task_finished == impl_->items.size() && impl_->nbatch_handle_task_finished == impl_->opt.nbatch_handler) return true; |
| 298 | co_cond_timedwait(impl_->cond, 1000); |
| 299 | return false; |
| 300 | } |
| 301 | |
| 302 | |
| 303 | void Consumer::HandleRoutineFunc(const int idx) { |
nothing calls this directly
no outgoing calls
no test coverage detected