3 writes to _currentAdders
System.Collections.Concurrent (3)
System\Collections\Concurrent\BlockingCollection.cs (3)
456
if (Interlocked.CompareExchange(ref
_currentAdders
, observedAdders + 1, observedAdders) == observedAdders)
493
Interlocked.Decrement(ref
_currentAdders
);
1456
if (Interlocked.CompareExchange(ref
_currentAdders
, observedAdders | COMPLETE_ADDING_ON_MASK, observedAdders) == observedAdders)
7 references to _currentAdders
System.Collections.Concurrent (7)
System\Collections\Concurrent\BlockingCollection.cs (7)
82
return (
_currentAdders
== COMPLETE_ADDING_ON_MASK);
447
int observedAdders =
_currentAdders
;
452
while (
_currentAdders
!= COMPLETE_ADDING_ON_MASK) spinner.SpinOnce();
492
Debug.Assert((
_currentAdders
& ~COMPLETE_ADDING_ON_MASK) > 0);
1447
int observedAdders =
_currentAdders
;
1452
while (
_currentAdders
!= COMPLETE_ADDING_ON_MASK) spinner.SpinOnce();
1459
while (
_currentAdders
!= COMPLETE_ADDING_ON_MASK) spinner.SpinOnce();