18 references to Unbounded
System.Threading.Tasks.Dataflow (18)
Base\DataflowBlockOptions.cs (11)
73
private int _maxMessagesPerTask =
Unbounded
;
75
private int _boundedCapacity =
Unbounded
;
137
if (value < 1 && value !=
Unbounded
) throw new ArgumentOutOfRangeException(nameof(value));
147
get { return (_maxMessagesPerTask ==
Unbounded
) ? int.MaxValue : _maxMessagesPerTask; }
157
if (value < 1 && value !=
Unbounded
) throw new ArgumentOutOfRangeException(nameof(value));
292
if (value < 1 && value !=
Unbounded
) throw new ArgumentOutOfRangeException(nameof(value));
324
get { return (_maxDegreeOfParallelism ==
Unbounded
) ? int.MaxValue : _maxDegreeOfParallelism; }
328
internal bool SupportsParallelExecution { get { return _maxDegreeOfParallelism ==
Unbounded
|| _maxDegreeOfParallelism > 1; } }
412
private long _maxNumberOfGroups =
Unbounded
;
435
if (value <= 0 && value !=
Unbounded
) throw new ArgumentOutOfRangeException(nameof(value));
445
get { return (_maxNumberOfGroups ==
Unbounded
) ? long.MaxValue : _maxNumberOfGroups; }
Base\DataflowLinkOptions.cs (1)
53
internal const int Unbounded = DataflowBlockOptions.
Unbounded
;
Blocks\ActionBlock.cs (1)
90
dataflowBlockOptions.BoundedCapacity == DataflowBlockOptions.
Unbounded
)
Blocks\BatchedJoinBlock.cs (2)
60
if (dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.
Unbounded
) throw new ArgumentException(SR.Argument_BoundedCapacityNotSupported, nameof(dataflowBlockOptions));
308
dataflowBlockOptions.BoundedCapacity != DataflowBlockOptions.
Unbounded
)
Internal\SourceCore.cs (1)
822
_dataflowBlockOptions.MaxMessagesPerTask == DataflowBlockOptions.
Unbounded
?
Internal\TargetCore.cs (2)
127
if (_dataflowBlockOptions.BoundedCapacity != System.Threading.Tasks.Dataflow.DataflowBlockOptions.
Unbounded
)
617
System.Threading.Tasks.Dataflow.DataflowBlockOptions.
Unbounded
, "Only valid to use when in bounded mode.");