◆ Execute()

void System.Threading.Tasks.TaskReplicator.Replica< TState >.Execute ( )

inline

Definition at line 45 of file TaskReplicator.cs.

        {
            try
            {
                if (!_replicator._stopReplicating && _remainingConcurrency > 0)
                {
                    CreateNewReplica();
                    _remainingConcurrency = 0;
                }
                ExecuteAction(out var yieldedBeforeCompletion);
                if (yieldedBeforeCompletion)
                {
                    _pendingTask = new Task(delegate(object s)
                    {
                        ((Replica)s).Execute();
                    }, this, CancellationToken.None, TaskCreationOptions.None);
                    _pendingTask.Start(_replicator._scheduler);
                }
                else
                {
                    _replicator._stopReplicating = true;
                    _pendingTask = null;
                }
            }
            catch (Exception item)
            {
                LazyInitializer.EnsureInitialized(ref _replicator._exceptions).Enqueue(item);
                if (_replicator._stopOnFirstFailure)
                {
                    _replicator._stopReplicating = true;
                }
                _pendingTask = null;
            }
        }