RunSynchronously()

void System.Linq.Parallel.ForAllOperator< TInput >.RunSynchronously ( )

inlinepackage

Definition at line 56 of file ForAllOperator.cs.

    {
        Shared<bool> topLevelDisposedFlag = new Shared<bool>(value: false);
        CancellationTokenSource topLevelCancellationTokenSource = new CancellationTokenSource();
        QuerySettings querySettings = base.SpecifiedQuerySettings.WithPerExecutionSettings(topLevelCancellationTokenSource, topLevelDisposedFlag).WithDefaults();
        QueryLifecycle.LogicalQueryExecutionBegin(querySettings.QueryId);
        IEnumerator<TInput> openedEnumerator = GetOpenedEnumerator(ParallelMergeOptions.FullyBuffered, suppressOrder: true, forEffect: true, querySettings);
        querySettings.CleanStateAtQueryEnd();
        QueryLifecycle.LogicalQueryExecutionEnd(querySettings.QueryId);
    }

References System.Linq.Parallel.QueryLifecycle.LogicalQueryExecutionBegin(), System.Linq.Parallel.QueryLifecycle.LogicalQueryExecutionEnd(), and System.value.