8 writes to _continuation
System.Threading.Channels (8)
System\Threading\Channels\AsyncOperation.cs (8)
108_continuation = pooled ? s_availableSentinel : null; 207if (_continuation is not null || Interlocked.CompareExchange(ref _continuation, s_completedSentinel, null) is not null) 273_continuation = s_completedSentinel; 282thisRef._continuation = s_completedSentinel; 351Action<object?>? prevContinuation = Interlocked.CompareExchange(ref _continuation, continuation, null); 463Volatile.Write(ref _continuation, s_availableSentinel); // only after fetching all needed data 508Volatile.Write(ref _continuation, s_availableSentinel); // only after fetching all needed data 520if (ReferenceEquals(Interlocked.CompareExchange(ref _continuation, null, s_availableSentinel), s_availableSentinel))
7 references to _continuation
System.Threading.Channels (7)
System\Threading\Channels\AsyncOperation.cs (7)
76/// <summary>State object to be passed to <see cref="_continuation"/>.</summary> 142internal bool IsCompleted => ReferenceEquals(_continuation, s_completedSentinel); 207if (_continuation is not null || Interlocked.CompareExchange(ref _continuation, s_completedSentinel, null) is not null) 209Debug.Assert(_continuation != s_completedSentinel, $"The continuation was the completion sentinel."); 210Debug.Assert(_continuation != s_availableSentinel, $"The continuation was the available sentinel."); 272Action<object?> c = _continuation!; 281Action<object?> c = thisRef._continuation!;