Method ProcessAllBatchHandleTasks

phxqueue/consumer/consumer.cpp:408–414

}

void Consumer::ProcessAllBatchHandleTasks(const int cid) {
    if (!impl_->batch_handle_finish[cid]) {
        BatchHandleRoutineFunc(cid);
        BatchHandleTaskFinish();
        impl_->batch_handle_finish[cid] = true;
    }
}

void Consumer::ConsumeThreadRun(const int vpid) {
    OnConsumeThreadRun(vpid);