modules/platforms/dotnet/Apache.Ignite.Core/Impl/Compute/ComputeImpl.cs
/// <summary>
/// Executes collection of jobs on nodes within this grid projection.
/// </summary>
/// <param name="clos">Collection of jobs to execute.</param>
/// <returns>Collection of job results for this execution.</returns>
Executes collection of jobs on nodes within this grid projection.
Executes collection of jobs on nodes within this grid projection .
public Future<ICollection<TJobRes>> Execute<TJobRes>(IEnumerable<IComputeFunc<TJobRes>> clos)
        {
            IgniteArgumentCheck.NotNull(clos, "clos");
            ICollection<IComputeJob> jobs = new List<IComputeJob>(GetCountOrZero(clos));
            foreach (IComputeFunc<TJobRes> clo in clos)
                jobs.Add(new ComputeOutFuncJob(clo.ToNonGeneric()));
            return ExecuteClosures0(new ComputeMultiClosureTask<object, TJobRes, ICollection<TJobRes>>(jobs.Count),
                null, jobs, false);
        }
public Future < ICollection < TJobRes > > Execute < TJobRes > ( IEnumerable < IComputeFunc < TJobRes > > clos ) { IgniteArgumentCheck . NotNull ( clos , " " ) ; ICollection < IComputeJob > jobs = new List < IComputeJob > ( GetCountOrZero ( clos ) ) ; foreach ( IComputeFunc < TJobRes > clo in clos ) jobs . Add ( new ComputeOutFuncJob ( clo . ToNonGeneric ( ) ) ) ; return ExecuteClosures0 ( new ComputeMultiClosureTask < object , TJobRes , ICollection < TJobRes > > ( jobs . Count ) , null , jobs , false ) ; }
Executes collection of jobs on nodes within this grid projection.
Executes collection of jobs on nodes within this grid projection .
Collection of job results for this execution.
Collection of job results for this execution .
clos
IEnumerable<IComputeFunc<TJobRes>>
Collection of jobs to execute.
Collection of jobs to execute .