3 writes to AcceptFewerThanBatchSize
System.Threading.Tasks.Dataflow (3)
Blocks\BatchBlock.cs (3)
340
_nonGreedyState.
AcceptFewerThanBatchSize
= true;
676
bool triggered = Volatile.Read(ref _nonGreedyState.
AcceptFewerThanBatchSize
);
693
if (madeProgress || triggered) _nonGreedyState.
AcceptFewerThanBatchSize
= false;
2 references to AcceptFewerThanBatchSize
System.Threading.Tasks.Dataflow (2)
Blocks\BatchBlock.cs (2)
580
if (_nonGreedyState.
AcceptFewerThanBatchSize
&& _messages.Count > 0)
589
if (_nonGreedyState.
AcceptFewerThanBatchSize
&& _nonGreedyState.PostponedMessages.Count > 0 && boundedCapacityAvailable > 0)