MCPcopy Create free account
hub / github.com/Tencent/phxqueue / Run

Method Run

phxqueue/scheduler/loadbalancethread.cpp:53–59  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

51}
52
53void LoadBalanceThread::Run() {
54 if (!impl_->t) {
55 impl_->stop = false;
56 impl_->t = unique_ptr<thread>(new thread(&LoadBalanceThread::DoRun, this));
57 }
58 assert(impl_->t);
59}
60
61void LoadBalanceThread::Stop() {
62 if (impl_->t) {

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected