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

Method Dispatcher

library/cpp/neh/jobqueue.cpp:42–52  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

40 }
41
42 inline void Dispatcher(TCont* c) {
43 IJob* job;
44
45 while ((job = Q_.Dequeue(c))) {
46 try {
47 c->Executor()->Create(*job, "job");
48 } catch (...) {
49 (*job)(c);
50 }
51 }
52 }
53
54 typedef TAutoPtr<IThreadFactory::IThread> IThreadRef;
55 TOneConsumerPipeQueue<IJob> Q_;

Callers

nothing calls this directly

Calls 3

DequeueMethod · 0.45
CreateMethod · 0.45
ExecutorMethod · 0.45

Tested by

no test coverage detected