1 write to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (1)
Internal\TargetCore.cs (1)
122_dataflowBlockOptions = dataflowBlockOptions;
15 references to _dataflowBlockOptions
System.Threading.Tasks.Dataflow (15)
Internal\TargetCore.cs (15)
127if (_dataflowBlockOptions.BoundedCapacity != System.Threading.Tasks.Dataflow.DataflowBlockOptions.Unbounded) 129Debug.Assert(_dataflowBlockOptions.BoundedCapacity > 0, "Positive bounding count expected; should have been verified by options ctor"); 130_boundingState = new BoundingStateWithPostponed<TInput>(_dataflowBlockOptions.BoundedCapacity); 302return (_numberOfOutstandingOperations - _numberOfOutstandingServiceTasks) < _dataflowBlockOptions.ActualMaxDegreeOfParallelism; 331_numberOfOutstandingServiceTasks < _dataflowBlockOptions.ActualMaxDegreeOfParallelism; 384Exception? exception = Common.StartTaskSafe(taskForInputProcessing, _dataflowBlockOptions.TaskScheduler); 407int maxMessagesPerTask = _dataflowBlockOptions.ActualMaxMessagesPerTask; 426&& _boundingState.OutstandingTransfers <= _dataflowBlockOptions.ActualMaxDegreeOfParallelism, 446if (_dataflowBlockOptions.MaxDegreeOfParallelism != 1) break; 616_dataflowBlockOptions.BoundedCapacity != 708return _dataflowBlockOptions.CancellationToken.IsCancellationRequested || Volatile.Read(ref _exceptions) != null; 784else if (_dataflowBlockOptions.CancellationToken.IsCancellationRequested) 786_completionSource.TrySetCanceled(_dataflowBlockOptions.CancellationToken); 837internal ExecutionDataflowBlockOptions DataflowBlockOptions { get { return _dataflowBlockOptions; } } 868internal ExecutionDataflowBlockOptions DataflowBlockOptions { get { return _target._dataflowBlockOptions; } }