MCPcopy Create free account
hub / github.com/catboost/catboost / DoExecute

Method DoExecute

library/cpp/dns/thread.cpp:103–119  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

101 }
102
103 void DoExecute() override {
104 while (true) {
105 TResolveRequest* rr = nullptr;
106
107 while (!Q_.Dequeue(&rr)) {
108 E_.Wait();
109 }
110
111 if (rr) {
112 rr->Resolve();
113 } else {
114 break;
115 }
116 }
117
118 Schedule(nullptr);
119 }
120
121 private:
122 TLockFreeQueue<TResolveRequest*> Q_;

Callers

nothing calls this directly

Calls 3

DequeueMethod · 0.45
WaitMethod · 0.45
ResolveMethod · 0.45

Tested by

no test coverage detected