Function HandleRoutineRun

phxqueue/consumer/consumer.cpp:360–373

}

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

    ConsumeCtx_t *ctx = static_cast<ConsumeCtx_t*>(arg);

    while (1) {
        if (ctx->consumer->HasHandleTasks(ctx->cid)) {
            co_yield_ct();
            continue;
        }
        ctx->consumer->ProcessAllHandleTasks(ctx->cid);
    }
    return nullptr;
}

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