Method Stop

phxqueue/producer/batchhelper.cpp:246–252

}

void BatchHelper::Stop() {
    impl_->stop = true;
    for (auto &&t : impl_->daemon_threads) {
        t->join();
        t.release();
    }
}

static int DispatchTickRun(void *arg) {
    DispatchCtx_t *ctx = static_cast<DispatchCtx_t*>(arg);