3 writes to AcceptFewerThanBatchSize
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (3)
343
_nonGreedyState.
AcceptFewerThanBatchSize
= true;
679
bool triggered = Volatile.Read(ref _nonGreedyState.
AcceptFewerThanBatchSize
);
696
if (madeProgress || triggered) _nonGreedyState.
AcceptFewerThanBatchSize
= false;
2 references to AcceptFewerThanBatchSize
System.Threading.Tasks.Dataflow (2)
Blocks\BatchBlock.cs (2)
583
if (_nonGreedyState.
AcceptFewerThanBatchSize
&& _messages.Count > 0)
592
if (_nonGreedyState.
AcceptFewerThanBatchSize
&& _nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0)