Method DoExecute

library/cpp/neh/multiclient_ut.cpp:63–85

    private:
        void DoExecute() override {
            for (;;) {
                TInstant tm = TInstant::Max();
                TTmResponse* resp = nullptr;
                {
                    TGuard<TMutex> g(M_);
                    for (TIntrusiveList<TTmResponse>::TIterator it = R_.Begin(); it != R_.End(); ++it) {
                        if (it->Time < tm) {
                            tm = it->Time;
                            resp = &*it;
                        }
                    }
                }
                if (!E_.WaitD(tm)) {
                    resp->Request->SendReply(resp->Data);
                    TGuard<TMutex> g(M_);
                    delete resp;
                }
                if (Shutdown_) {
                    break;
                }
            }
        }

    private:
        TAutoPtr<IThreadFactory::IThread> Thr_;