1 write to _replicator
System.Threading.Tasks.Parallel (1)
System\Threading\Tasks\TaskReplicator.cs (1)
35_replicator = replicator;
10 references to _replicator
System.Threading.Tasks.Parallel (10)
System\Threading\Tasks\TaskReplicator.cs (10)
39_replicator._pendingReplicas.Enqueue(this); 44_pendingTask!.RunSynchronously(_replicator._scheduler); 68if (!_replicator._stopReplicating && _remainingConcurrency > 0) 81_pendingTask.Start(_replicator._scheduler); 85_replicator._stopReplicating = true; 91LazyInitializer.EnsureInitialized(ref _replicator._exceptions).Enqueue(ex); 92if (_replicator._stopOnFirstFailure) 93_replicator._stopReplicating = true; 115Replica<TState> newReplica = new Replica<TState>(_replicator, _remainingConcurrency, GenerateCooperativeMultitaskingTaskTimeout(), _action); 116newReplica._pendingTask!.Start(_replicator._scheduler);