2 writes to _activeConsumer
System.Threading.Tasks.Dataflow (2)
Internal\SpscTargetCore.cs (2)
169if (Interlocked.CompareExchange(ref _activeConsumer, newConsumer, null) == null) 255Task? previousConsumer = Interlocked.Exchange<Task?>(ref _activeConsumer, null);
6 references to _activeConsumer
System.Threading.Tasks.Dataflow (6)
Internal\SpscTargetCore.cs (6)
102if (_activeConsumer == null) 151if (_activeConsumer == null) 163if (_activeConsumer == null) 194_activeConsumer != null && _activeConsumer.Id == Task.CurrentId, 394internal int CurrentDegreeOfParallelism { get { return _target._activeConsumer != null && !_target.Completion.IsCompleted ? 1 : 0; } }