13 references to CountdownEvent
Aspire.Dashboard.Tests (2)
Telemetry\AzureMonitorTelemetryProviderTests.cs (2)
79
using var entered = new
CountdownEvent
(2);
117
using var entered = new
CountdownEvent
(2);
Aspire.Hosting.RemoteHost.Tests (1)
IntegrationHostDiscoveryThreadPoolTests.cs (1)
49
var slotsOccupied = new
CountdownEvent
(slots);
Aspire.Hosting.Tests (1)
Eventing\DistributedApplicationBuilderEventingTests.cs (1)
236
var countdownEvent = new
CountdownEvent
(2);
Client.ExpectedExceptions.IntegrationTests (1)
NamedPipeConnectionTests.cs (1)
55
using CountdownEvent ready = new
CountdownEvent
(ConnectionCount);
Microsoft.Build.Utilities.Core (1)
ToolTask.cs (1)
768
_eofCountdown = new
CountdownEvent
(2);
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);