| 289 | } |
| 290 | |
| 291 | void Consumer::BatchHandleTaskFinish() { |
| 292 | ++impl_->nbatch_handle_task_finished; |
| 293 | if (impl_->nhandle_task_finished == impl_->items.size() && impl_->nbatch_handle_task_finished == impl_->opt.nbatch_handler) co_cond_signal(impl_->cond); |
| 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; |
nothing calls this directly
no outgoing calls
no test coverage detected