Method Run

phxqueue/producer/batchhelper.cpp:239–244

}

void BatchHelper::Run() {
    impl_->stop = false;
    for (int i{0}; i < impl_->ndaemon_thread; ++i) {
        impl_->daemon_threads.push_back(move(unique_ptr<thread>(new thread(&BatchHelper::DaemonThreadRun, this, i))));
    }
}

void BatchHelper::Stop() {
    impl_->stop = true;