4 writes to BoundedCapacity
System.Threading.Tasks.Dataflow (4)
Base\DataflowBlock.cs (1)
2162private 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)
84dataflowBlockOptions.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) 318bool boundingEnabled = dataflowBlockOptions.BoundedCapacity > 0; 320if (boundingEnabled) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity); 492_dataflowBlockOptions.BoundedCapacity - _boundingState.CurrentCount :
Blocks\BatchedJoinBlock.cs (2)
60if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded) throw new ArgumentException(SR.Argument_BoundedCapacityNotSupported, nameof(dataflowBlockOptions)); 305dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.Unbounded)
Blocks\BroadcastBlock.cs (3)
74if (dataflowBlockOptions.BoundedCapacity > 0) 76Debug.Assert(dataflowBlockOptions.BoundedCapacity > 0, "Positive bounding count expected; should have been verified by options ctor"); 78_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
Blocks\BufferBlock.cs (2)
55if (dataflowBlockOptions.BoundedCapacity > 0) 58_boundingState = new BoundingStateWithPostponedAndTask<T>(dataflowBlockOptions.BoundedCapacity);
Blocks\JoinBlock.cs (5)
59if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2>)owningSource)._sharedResources.OnItemsRemoved(count); 280if (dataflowBlockOptions.BoundedCapacity > 0) onItemsRemoved = static (owningSource, count) => ((JoinBlock<T1, T2, T3>)owningSource)._sharedResources.OnItemsRemoved(count); 507if (!dbo.Greedy || dbo.BoundedCapacity > 0) _nonGreedy = new NonGreedyState(); 1042if (dataflowBlockOptions.BoundedCapacity > 0) _boundingState = new BoundingState(dataflowBlockOptions.BoundedCapacity);
Blocks\TransformBlock.cs (1)
105if (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 !=