Method Run

phxqueue/lock/cleanthread.cpp:61–67

}

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

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