TryDequeue

88 references to TryDequeue

aspire (1)

Projects\ProjectUpdater.cs (1)

162while (context.AnalyzeSteps.TryDequeue(out var analyzeStep))

Aspire.Confluent.Kafka (3)

ConfluentKafkaMetrics.cs (3)

87while (ReplyQueueMeasurements.TryDequeue(out var measurement)) 95while (MessageCountMeasurements.TryDequeue(out var measurement)) 103while (MessageSizeMeasurements.TryDequeue(out var measurement))

Aspire.Hosting.Analyzers (1)

AppHostAnalyzer.cs (1)

38if (!concurrentQueue.TryDequeue(out var modelNameOperations))

dotnet (1)

Commands\Test\MTP\MSBuildUtility.cs (1)

487if (gracefulExceptions.TryDequeue(out GracefulException? gracefulException))

dotnet-svcutil-lib (1)

FrameworkFork\System.ServiceModel\Internals\System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)

458if (s_freeStringBuilders.TryDequeue(out sb))

ILCompiler.ReadyToRun (1)

Compiler\DependencyAnalysis\ReadyToRun\TypeValidationChecker.cs (1)

64while (_tasksThatMustFinish.TryDequeue(out var taskToComplete))

Microsoft.AspNetCore.App.Analyzers (2)

Mvc\MvcAnalyzer.cs (1)

50if (!concurrentQueue.TryDequeue(out var pooledItems))

RouteHandlers\RouteHandlerAnalyzer.cs (1)

51if (!concurrentQueue.TryDequeue(out var mapOperations))

Microsoft.AspNetCore.Components.Server (2)

Circuits\RemoteRenderer.cs (2)

137while (_unacknowledgedRenderBatches.TryDequeue(out var entry)) 281_unacknowledgedRenderBatches.TryDequeue(out _);

Microsoft.AspNetCore.Diagnostics.Middleware (2)

Buffering\IncomingRequestLogBuffer.cs (2)

122for (int i = 0; i < currentBatchSize && tempBuffer.TryDequeue(out SerializedLogRecord bufferedRecord); i++) 157_activeBuffer.TryDequeue(out SerializedLogRecord item))

Microsoft.AspNetCore.Http (1)

src\aspnetcore\src\Shared\CancellationTokenSourcePool.cs (1)

17if (_queue.TryDequeue(out var cts))

Microsoft.AspNetCore.OutputCaching (1)

RecyclableReadOnlySequenceSegment.cs (1)

29var obj = s_Spares.TryDequeue(out var value) ? value : new();

Microsoft.AspNetCore.Server.HttpSys (3)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

103if (_blocks.TryDequeue(out var block)) 215while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 245while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.IIS (3)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

103if (_blocks.TryDequeue(out var block)) 215while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 245while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.Kestrel.Core (6)

Internal\Http2\Http2Connection.cs (2)

1452while (_completedStreams.TryDequeue(out var stream)) 1515while (_streams.Count >= maxStreams && _completedStreams.TryDequeue(out var stream))

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

103if (_blocks.TryDequeue(out var block)) 215while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 245while (_blocks.TryDequeue(out _))

src\aspnetcore\src\Shared\CancellationTokenSourcePool.cs (1)

17if (_queue.TryDequeue(out var cts))

Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (3)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

103if (_blocks.TryDequeue(out var block)) 215while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 245while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (3)

src\aspnetcore\src\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

103if (_blocks.TryDequeue(out var block)) 215while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 245while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets (3)

Internal\IOQueue.cs (1)

34while (_workItems.TryDequeue(out Work item))

Internal\SocketSenderPool.cs (2)

27if (_queue.TryDequeue(out var sender)) 54while (_queue.TryDequeue(out var sender))

Microsoft.Build (14)

BackEnd\Client\MSBuildClient.cs (1)

709while (packetPump.ReceivedPacketsQueue.TryDequeue(out INodePacket? packet) &&

BackEnd\Components\Communications\NodeEndpointInProc.cs (1)

444while (_packetQueue.TryDequeue(out packet))

BackEnd\Components\Communications\NodeProviderOutOfProcBase.cs (2)

320while (possibleRunningNodes != null && possibleRunningNodes.TryDequeue(out var nodeToReuse)) 1260while (context._packetWriteQueue.TryDequeue(out INodePacket packet))

BackEnd\Components\Logging\LoggingService.cs (1)

1500if (eventQueue.TryDequeue(out object ev))

BackEnd\Node\InProcNode.cs (1)

167while (_receivedPackets.TryDequeue(out INodePacket packet))

BackEnd\Node\OutOfProcNode.cs (1)

272while (_receivedPackets.TryDequeue(out INodePacket packet))

BackEnd\Node\OutOfProcServerNode.cs (1)

180while (_receivedPackets.TryDequeue(out INodePacket? packet))

Collections\ConcurrentQueueExtensions.cs (1)

21Assumed.True(stack.TryDequeue(out T result), "Unable to dequeue from queue");

Graph\ParallelWorkSet.cs (1)

195if (_queue.TryDequeue(out WorkItem workItem))

Instance\TaskFactories\TaskHostTask.cs (1)

400while (_receivedPackets.TryDequeue(out packet))

Logging\ProfilerLogger.cs (1)

140var result = _profiledResults.TryDequeue(out profiledResult);

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (1)

877while (localPacketQueue.TryDequeue(out packet))

Utilities\AwaitExtensions.cs (1)

178if (_queuedTasks.TryDequeue(out t))

Microsoft.Build.Tasks.Core (2)

Copy.cs (2)

574if (_copyActionQueue.TryDequeue(out Action copyAction)) 670while (partitionQueue.TryDequeue(out List<int> partition))

Microsoft.Extensions.Diagnostics.Testing.Tests (1)

Logging\FakeLogCollectorTests.LogEnumeration.cs (1)

213while (eventTracker.TryDequeue(out var item))

Microsoft.Extensions.Http (1)

DefaultHttpClientFactory.cs (1)

278_expiredHandlers.TryDequeue(out ExpiredHandlerTrackingEntry? entry);

Microsoft.Extensions.ObjectPool (2)

DefaultObjectPool.cs (1)

53if (_items.TryDequeue(out item))

DisposableObjectPool.cs (1)

54while (_items.TryDequeue(out var item))

Microsoft.ML.Core (2)

Data\ProgressReporter.cs (2)

440while (_pendingEvents.TryDequeue(out cur)) 474_pendingEvents.TryDequeue(out var res);

Microsoft.ML.Data (1)

DataLoadSave\Text\BlockingQueue.cs (1)

95bool gotItem = _queue.TryDequeue(out item);

Microsoft.ML.FastTree (1)

Training\Applications\ObjectiveFunction.cs (1)

73Contracts.Check(queue.TryDequeue(out threadIndex));

MSBuild (1)

src\msbuild\src\Shared\NodeEndpointOutOfProcBase.cs (1)

877while (localPacketQueue.TryDequeue(out packet))

NuGet.DependencyResolver.Core (1)

Remote\RemoteDependencyWalker.cs (1)

646return _toBeProcessedTransitiveCentralPackageVersions.TryDequeue(out centralPackageVersionDependency);

NuGet.PackageManagement (2)

IDE\PackageRestoreManager.cs (2)

479while (packageReferencesQueue.TryDequeue(out currentPackageReference)) 585while (packageReferencesQueue.TryDequeue(out currentPackageReference))

NuGet.Protocol (1)

Utility\DedicatedAsynchronousProcessingThread.cs (1)

63if (_taskQueue.TryDequeue(out var result))

System.Data.Odbc (1)

Common\System\Data\ProviderBase\DbConnectionPool.cs (1)

603while (_pendingOpens.TryDequeue(out next))

System.Data.OleDb (1)

System\Data\ProviderBase\DbConnectionPool.cs (1)

953while (_pendingOpens.TryDequeue(out next))

System.Net.Sockets (1)

System\Net\Sockets\SocketAsyncEngine.Unix.cs (1)

328_eventPool.TryDequeue(out SocketIOEvent? existingEvent) ?

System.Private.CoreLib (8)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

23bool IProducerConsumerQueue<T>.TryDequeue([MaybeNullWhen(false)] out T result) { return TryDequeue(out result); }

src\runtime\src\libraries\System.Private.CoreLib\src\System\Collections\Concurrent\ConcurrentQueue.cs (1)

201bool IProducerConsumerCollection<T>.TryTake([MaybeNullWhen(false)] out T item) => TryDequeue(out item);

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\ThreadPoolWorkQueue.cs (6)

562while (_assignedWorkItemQueueThreadCounts[queueIndex] <= 0 && queue.TryDequeue(out object? workItem)) 752if (highPriorityWorkItems.TryDequeue(out workItem)) 770if (s_assignableWorkItemQueueCount > 0 && tl.assignedGlobalWorkItemQueue.TryDequeue(out workItem)) 776if (workItems.TryDequeue(out workItem)) 790if (i != queueIndex && _assignableWorkItemQueues[i].TryDequeue(out workItem)) 836if (!highPriorityWorkItems.TryDequeue(out workItem))

System.ServiceModel.Primitives (1)

Internals\System\Runtime\Diagnostics\EtwDiagnosticTrace.cs (1)

355if (s_freeStringBuilders.TryDequeue(out sb))

System.Threading.Channels (4)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

23bool IProducerConsumerQueue<T>.TryDequeue([MaybeNullWhen(false)] out T result) { return TryDequeue(out result); }

System\Threading\Channels\UnboundedChannel.cs (3)

77if (parent._items.TryDequeue(out T? item)) 88if (parent._items.TryDequeue(out item)) 114if (parent._items.TryDequeue(out item))

System.Threading.Tasks.Dataflow (1)

src\runtime\src\libraries\Common\src\System\Collections\Concurrent\MultiProducerMultiConsumerQueue.cs (1)

23bool IProducerConsumerQueue<T>.TryDequeue([MaybeNullWhen(false)] out T result) { return TryDequeue(out result); }

System.Threading.Tasks.Parallel (1)

System\Threading\Tasks\TaskReplicator.cs (1)

153while (replicator._pendingReplicas.TryDequeue(out nextReplica))

System.Transactions.Local (4)

System\Transactions\DtcProxyShim\DtcProxyShimFactory.cs (4)

292bool entryRemoved = _notifications.TryDequeue(out NotificationShimBase? notification); 344if (_cachedOptions.TryDequeue(out ITransactionOptions? options)) 358if (!_cachedTransmitters.TryDequeue(out ITransactionTransmitter? transmitter)) 382if (_cachedReceivers.TryDequeue(out ITransactionReceiver? receiver))