Method Stop

library/cpp/par/par_host.cpp:65–78

    }

    void TRootEnvironment::Stop() {
        ContextMaster->WaitAllDistributionActivity();
        if (QueryProc.Get()) {
            QueryProc->StopSlaves();
        }
        Y_ASSERT(LocalExecutor().GetQueueSize() == 0);
        LocalExecutor().ClearLPQueue();
        ContextMaster = nullptr;
        Master = nullptr;
        if (QueryProc.Get()) {
            QueryProc->Stop();
            QueryProc = nullptr;
        }
    }

    //////////////////////////////////////////////////////////////////////////
    void RunSlave(int workerThreadCount, int port) {