Method BatchHandleRoutineFunc

phxqueue/consumer/consumer.cpp:336–350

}

void Consumer::BatchHandleRoutineFunc(const int idx) {
    comm::ConsumerConsumeBP::GetThreadInstance()->OnBatchHandleRoutineFunc(impl_->cc, idx);

    BeforeBatchHandle(impl_->cc, impl_->items, idx);

    comm::RetCode ret;
    if (comm::RetCode::RET_OK != (ret = BatchHandle(impl_->cc, impl_->items, idx))) {
        QLErr("Handle ret %d", comm::as_integer(ret));
        return;
    }

    AfterBatchHandle(impl_->cc, impl_->items, idx);

    return;
}

static void *DispatchRoutineRun(void *arg) {
    co_enable_hook_sys();