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)
319if (!_dataflowBlockOptions.Greedy || boundingEnabled) _nonGreedyState = new NonGreedyState(batchSize); 370if (_dataflowBlockOptions.Greedy && 412if (!_dataflowBlockOptions.Greedy) ProcessAsyncIfNecessary(); 592if (_dataflowBlockOptions.Greedy) 681if (!_dataflowBlockOptions.Greedy) RetrievePostponedItemsNonGreedy(allowFewerThanBatchSize: triggered); 752Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 869Debug.Assert(_dataflowBlockOptions.Greedy, "This method may only be used in greedy mode."); 978Debug.Assert(!_dataflowBlockOptions.Greedy, "This method may only be used in non-greedy mode."); 1028Debug.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)); 304if (!dataflowBlockOptions.Greedy ||
Blocks\JoinBlock.cs (16)
507if (!dbo.Greedy || dbo.BoundedCapacity > 0) _nonGreedy = new NonGreedyState(); 508if (dbo.Greedy) _messages = new Queue<T>(); 516if (_sharedResources._dataflowBlockOptions.Greedy) 547if (_sharedResources._dataflowBlockOptions.Greedy) 575return !_sharedResources._dataflowBlockOptions.Greedy ? _nonGreedy!.PostponedMessages.Count : _messages!.Count; 584Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only valid in greedy mode"); 601Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 641Debug.Assert(!_sharedResources._dataflowBlockOptions.Greedy, "This is only used in non-greedy mode"); 683Debug.Assert(_sharedResources._dataflowBlockOptions.Greedy, "This is only used in greedy mode"); 729int messageCount = _sharedResources._dataflowBlockOptions.Greedy ? 835if (_sharedResources._dataflowBlockOptions.Greedy && 885bool greedy = _sharedResources._dataflowBlockOptions.Greedy; 1133if (_dataflowBlockOptions.Greedy && targetCanConsumePostponedMessages && (boundingCapacityAvailable || !target.HasTheHighestNumberOfMessagesAvailable)) return true; 1343Debug.Assert(!_dataflowBlockOptions.Greedy || _boundingState != null, "This only makes sense in non-greedy or bounding mode"); 1355madeProgress = !_dataflowBlockOptions.Greedy ? 1370if (!_dataflowBlockOptions.Greedy && _boundingState != null) _boundingState.CurrentCount += 1;