1 write to _replicator
System.Threading.Tasks.Parallel (1)
System\Threading\Tasks\TaskReplicator.cs (1)
34_replicator = replicator;
10 references to _replicator
System.Threading.Tasks.Parallel (10)
System\Threading\Tasks\TaskReplicator.cs (10)
38_replicator._pendingReplicas.Enqueue(this); 43_pendingTask!.RunSynchronously(_replicator._scheduler); 67if (!_replicator._stopReplicating && _remainingConcurrency > 0) 80_pendingTask.Start(_replicator._scheduler); 84_replicator._stopReplicating = true; 90LazyInitializer.EnsureInitialized(ref _replicator._exceptions).Enqueue(ex); 91if (_replicator._stopOnFirstFailure) 92_replicator._stopReplicating = true; 114Replica<TState> newReplica = new Replica<TState>(_replicator, _remainingConcurrency, GenerateCooperativeMultitaskingTaskTimeout(), _action); 115newReplica._pendingTask!.Start(_replicator._scheduler);