Function DispatchRoutineRun

phxqueue/consumer/consumer.cpp:352–358

}

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

    DispatchCtx_t *ctx = static_cast<DispatchCtx_t*>(arg);
    ctx->consumer->TaskDispatch();
    return nullptr;
}

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