Function DispatchTickRun

phxqueue/producer/batchhelper.cpp:254–258

}

static int DispatchTickRun(void *arg) {
    DispatchCtx_t *ctx = static_cast<DispatchCtx_t*>(arg);
    ctx->batch_helper->DispatchBatchTask(ctx->vtid);
    return 0;
}

void BatchHelper::DispatchBatchTask(int vtid) {
    auto &batch_infos = impl_->vtid2batch_infos[vtid];