Method Run

phxqueue/store/keepsyncthread.cpp:63–69

}

void KeepSyncThread::Run() {
    if (!impl_->t) {
        impl_->stop = false;
        impl_->t = unique_ptr<thread>(new thread(&KeepSyncThread::DoRun, this));
    }
    assert(impl_->t);
}

void KeepSyncThread::Stop() {
    if (impl_->t) {