4 writes to BoundedCapacity
System.Threading.Tasks.Dataflow (4)
Base\DataflowBlock.cs (1)
2244private static readonly ExecutionDataflowBlockOptions _nonGreedyExecutionOptions = new ExecutionDataflowBlockOptions { BoundedCapacity = 1 };
Base\DataflowBlockOptions.cs (3)
98BoundedCapacity = this.BoundedCapacity, 269BoundedCapacity = this.BoundedCapacity, 401BoundedCapacity = this.BoundedCapacity,
28 references to BoundedCapacity
System.Threading.Tasks.Dataflow (28)
Base\DataflowBlockOptions.cs (3)
98BoundedCapacity = this.BoundedCapacity, 269BoundedCapacity = this.BoundedCapacity, 401BoundedCapacity = this.BoundedCapacity,
Blocks\ActionBlock.cs (1)
90dataflowBlockOptions.BoundedCapacity == DataflowBlockOptions.Unbounded)
Blocks\BatchBlock.cs (6)
51if (dataflowBlockOptions.BoundedCapacity > 0 && dataflowBlockOptions.BoundedCapacity < batchSize) throw new ArgumentOutOfRangeException(nameof(batchSize), SR.ArgumentOutOfRange_BatchSizeMustBeNoGreaterThanBoundedCapacity); 59if (dataflowBlockOptions.BoundedCapacity > 0) 321bool boundingEnabled = dataflowBlockOptions.BoundedCapacity > 0; 323if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity); 495_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount :
Blocks\BatchedJoinBlock.cs (2)
60if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) throw new ArgumentException(SR.Argument_BoundedCapacityNotSupported, nameof(dataflowBlockOptions)); 308dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded)
Blocks\BroadcastBlock.cs (3)
77if (dataflowBlockOptions.BoundedCapacity > 0) 79Debug.Assert(dataflowBlockOptions.BoundedCapacity > 0, "Positive bounding count expected; should have been verified by options ctor"); 81_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
Blocks\BufferBlock.cs (2)
58if (dataflowBlockOptions.BoundedCapacity > 0) 61_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
Blocks\JoinBlock.cs (5)
62if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2>)owningSource)._sharedResources.OnItemsRemoved(count); 289if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.OnItemsRemoved(count); 519if (!dbo.Greedy || dbo.BoundedCapacity > 0) _nonGreedy = new NonGreedyState(); 1057if (dataflowBlockOptions.BoundedCapacity > 0) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
Blocks\TransformBlock.cs (1)
108if (dataflowBlockOptions.BoundedCapacity > 0)
Blocks\TransformManyBlock.cs (1)
113if (dataflowBlockOptions.BoundedCapacity > 0)
Internal\TargetCore.cs (4)
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); 616_dataflowBlockOptions.BoundedCapacity !=