4 writes to _blockedReadersHead
System.Threading.Channels (4)
System\Threading\Channels\UnboundedChannel.cs (4)
104
ChannelUtilities.Enqueue(ref parent.
_blockedReadersHead
, reader);
214
parent.
_blockedReadersHead
= null;
254
blockedReader = ChannelUtilities.TryDequeueAndReserveCompletionIfCancelable(ref parent.
_blockedReadersHead
);
315
ChannelUtilities.Remove(ref state.Key.
_blockedReadersHead
, blockedReader);
3 references to _blockedReadersHead
System.Threading.Channels (3)
System\Threading\Channels\UnboundedChannel.cs (3)
212
blockedReadersHead = parent.
_blockedReadersHead
;
341
Debug.Assert(
_blockedReadersHead
is null, "There's data available, so there shouldn't be any blocked readers.");
347
if ((
_blockedReadersHead
is not null || _waitingReadersHead is not null) && _runContinuationsAsynchronously)