Method ExecAsync

library/cpp/par/par_util.cpp:289–298

            SharedCmd = new TSharedCmd(finalMap);
        }
        void ExecAsync(IUserContext* ctx, int hostId, TVector<char>* params, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            (void)hostId;
            TExecRange range;
            SerializeFromMem(params, range);

            TIntrusivePtr<TExecutor> exec;
            exec = new TExecutor(ctx, hostId, SharedCmd.Get(), range.Start, range.Finish, dcNotify, reqId);
            exec->Launch();
        }
        void MergeAsync(TVector<TVector<char>>* src, IDCResultNotify* dcNotify, int reqId) const override {
            CHROMIUM_TRACE_FUNCTION();
            SharedCmd->FinalMap->MergeAsync(src, dcNotify, reqId);