1 write to Greedy
System.Threading.Tasks.Dataflow (1)
Base\DataflowBlockOptions.cs (1)
404Greedy = this.Greedy,
28 references to Greedy
System.Threading.Tasks.Dataflow (28)
Base\DataflowBlockOptions.cs (1)
404Greedy = this.Greedy,
Blocks\BatchBlock.cs (9)
322if (!_dataflowBlockOptions.Greedy || boundingEnabled) _nonGreedyState = new NonGreedyState(batchSize); 373if (_dataflowBlockOptions.Greedy && 415if (!_dataflowBlockOptions.Greedy) ProcessAsyncIfNecessary(); 595if (_dataflowBlockOptions.Greedy) 684if (!_dataflowBlockOptions.Greedy) RetrievePostponedItemsNonGreedy(allowFewerThanBatchSize: triggered); 755Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 872Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 981Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 1031Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode.");
Blocks\BatchedJoinBlock.cs (2)
59if (!dataflowBlockOptions.Greedy) throw new ArgumentException(SR.Argument_NonGreedyNotSupported, nameof(dataflowBlockOptions)); 307if (!dataflowBlockOptions.Greedy ||
Blocks\JoinBlock.cs (16)
519if (!dbo.Greedy || dbo.BoundedCapacity > 0) _nonGreedy = new NonGreedyState(); 520if (dbo.Greedy) _messages = new Queue<T>(); 528if (_sharedResources._dataflowBlockOptions.Greedy) 559if (_sharedResources._dataflowBlockOptions.Greedy) 587return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 596Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only valid in greedy mode"); 613Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 653Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 695Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only used in greedy mode"); 741int messageCount = _sharedResources._dataflowBlockOptions.Greedy ? 847if (_sharedResources._dataflowBlockOptions.Greedy && 897bool greedy = _sharedResources._dataflowBlockOptions.Greedy; 1148if (_dataflowBlockOptions.Greedy && targetCanConsumePostponedMessages && (boundingCapacityAvailable || !target.HasTheHighestNumberOfMessagesAvailable)) return true; 1358Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1370madeProgress = !_dataflowBlockOptions.Greedy ? 1385if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1;