10 instantiations of CountdownEvent
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
53
var countdownEvent = new
CountdownEvent
(2);
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (2)
PersistentStorage\AbstractPersistentStorageTests.cs (2)
912
var countdown = new
CountdownEvent
(NumThreads);
944
var countdown = new
CountdownEvent
(NumThreads);
System.Linq.Parallel (7)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
27
CountdownEvent barrier = new
CountdownEvent
(inputStream.PartitionCount);
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
32
CountdownEvent barrier = new
CountdownEvent
(inputStream.PartitionCount);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (1)
66
CountdownEvent sharedLatch = new
CountdownEvent
(partitionCount - 1);
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (1)
80
CountdownEvent sharedBarrier = new
CountdownEvent
(partitionCount);
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (1)
80
CountdownEvent sharedBarrier = new
CountdownEvent
(partitionCount);
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (1)
109
CountdownEvent sharedBarrier = new
CountdownEvent
(partitionCount); // a barrier to synchronize before yielding
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (1)
135
CountdownEvent sharedBarrier = new
CountdownEvent
(partitionCount);
54 references to CountdownEvent
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
53
var
countdownEvent = new CountdownEvent(2);
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (2)
PersistentStorage\AbstractPersistentStorageTests.cs (2)
912
var
countdown = new CountdownEvent(NumThreads);
944
var
countdown = new CountdownEvent(NumThreads);
mscorlib (1)
src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1126
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.
CountdownEvent
))]
netstandard (1)
netstandard.cs (1)
2075
[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.
CountdownEvent
))]
System.Linq.Parallel (21)
System\Linq\Parallel\Partitioning\HashRepartitionEnumerator.cs (2)
35
private
CountdownEvent
_barrier; // Used to signal and wait for repartitions to complete.
67
CountdownEvent
barrier, ListChunk<Pair<TInputOutput, THashKey>>[][] valueExchangeMatrix, CancellationToken cancellationToken)
System\Linq\Parallel\Partitioning\OrderedHashRepartitionEnumerator.cs (2)
36
private
CountdownEvent
_barrier; // Used to signal and wait for repartitions to complete.
68
Func<TInputOutput, THashKey>? keySelector, OrderedHashRepartitionStream<TInputOutput, THashKey, TOrderKey> repartitionStream,
CountdownEvent
barrier,
System\Linq\Parallel\Partitioning\OrderedHashRepartitionStream.cs (1)
27
CountdownEvent
barrier = new CountdownEvent(inputStream.PartitionCount);
System\Linq\Parallel\Partitioning\UnorderedHashRepartitionStream.cs (1)
32
CountdownEvent
barrier = new CountdownEvent(inputStream.PartitionCount);
System\Linq\Parallel\QueryOperators\Unary\DefaultIfEmptyQueryOperator.cs (3)
66
CountdownEvent
sharedLatch = new CountdownEvent(partitionCount - 1);
114
private readonly
CountdownEvent
_sharedLatch; // Shared latch, signaled when partitions process the 1st item.
123
Shared<int> sharedEmptyCount,
CountdownEvent
sharedLatch, CancellationToken cancelToken)
System\Linq\Parallel\QueryOperators\Unary\FirstQueryOperator.cs (3)
80
CountdownEvent
sharedBarrier = new CountdownEvent(partitionCount);
130
private readonly
CountdownEvent
_sharedBarrier; // Shared barrier, signaled when partitions find their 1st element.
140
FirstQueryOperatorState<TKey> operatorState,
CountdownEvent
sharedBarrier, CancellationToken cancellationToken,
System\Linq\Parallel\QueryOperators\Unary\LastQueryOperator.cs (3)
80
CountdownEvent
sharedBarrier = new CountdownEvent(partitionCount);
126
private readonly
CountdownEvent
_sharedBarrier; // Shared barrier, signaled when partitions find their 1st element.
136
LastQueryOperatorState<TKey> operatorState,
CountdownEvent
sharedBarrier, CancellationToken cancelToken,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipQueryOperator.cs (3)
109
CountdownEvent
sharedBarrier = new CountdownEvent(partitionCount); // a barrier to synchronize before yielding
160
private readonly
CountdownEvent
_sharedBarrier; // To separate the search/yield phases.
172
FixedMaxHeap<TKey> sharedIndices,
CountdownEvent
sharedBarrier, CancellationToken cancellationToken,
System\Linq\Parallel\QueryOperators\Unary\TakeOrSkipWhileQueryOperator.cs (3)
135
CountdownEvent
sharedBarrier = new CountdownEvent(partitionCount);
215
private readonly
CountdownEvent
_sharedBarrier; // To separate the search/yield phases.
230
OperatorState<TKey> operatorState,
CountdownEvent
sharedBarrier, CancellationToken cancelToken, IComparer<TKey> keyComparer)
System.Threading (28)
System\Threading\CountdownEvent.cs (28)
19
/// All public and protected members of <see cref="
CountdownEvent
"/> are thread-safe and may be used
21
/// must only be used when all other operations on the <see cref="
CountdownEvent
"/> have
41
/// Initializes a new instance of <see cref="System.Threading.
CountdownEvent
"/> class with the
45
/// cref="System.Threading.
CountdownEvent
"/>.</param>
114
/// that rely on having a WaitHandle. If all that's needed is to wait for the <see cref="
CountdownEvent
"/>
127
/// Releases all resources used by the current instance of <see cref="System.Threading.
CountdownEvent
"/>.
130
/// Unlike most of the members of <see cref="
CountdownEvent
"/>, <see cref="Dispose()"/> is not
146
/// <see cref="System.Threading.
CountdownEvent
"/>, and optionally releases the managed resources.
151
/// Unlike most of the members of <see cref="
CountdownEvent
"/>, <see cref="Dispose()"/> is not
164
/// Registers a signal with the <see cref="System.Threading.
CountdownEvent
"/>, decrementing its
200
/// Registers multiple signals with the <see cref="System.Threading.
CountdownEvent
"/>,
254
/// Increments the <see cref="System.Threading.
CountdownEvent
"/>'s current count by one.
269
/// Attempts to increment the <see cref="System.Threading.
CountdownEvent
"/>'s current count by one.
283
/// Increments the <see cref="System.Threading.
CountdownEvent
"/>'s current count by a specified
304
/// Attempts to increment the <see cref="System.Threading.
CountdownEvent
"/>'s current count by a
356
/// Unlike most of the members of <see cref="
CountdownEvent
"/>, Reset is not
370
/// cref="System.Threading.
CountdownEvent
"/>.</param>
372
/// Unlike most of the members of <see cref="
CountdownEvent
"/>, Reset is not
398
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set.
416
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set, while
441
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set, using a
447
/// <returns>true if the <see cref="System.Threading.
CountdownEvent
"/> was set; otherwise,
467
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set, using
476
/// <returns>true if the <see cref="System.Threading.
CountdownEvent
"/> was set; otherwise,
498
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set, using a
503
/// <returns>true if the <see cref="System.Threading.
CountdownEvent
"/> was set; otherwise,
518
/// Blocks the current thread until the <see cref="System.Threading.
CountdownEvent
"/> is set, using a
526
/// <returns>true if the <see cref="System.Threading.
CountdownEvent
"/> was set; otherwise,