TryDequeue

96 references to TryDequeue

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-svcutil-lib (1)

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

458if (s_freeStringBuilders.TryDequeue(out sb))

InMemory.FunctionalTests (3)

ResponseTests.cs (1)

2267while (LogMessages.TryDequeue(out var message))

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

462if (!_streamContextPool.TryDequeue(out var testStreamContext))

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.TryDequeue(out _); });

Interop.FunctionalTests (3)

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

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

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.ConcurrencyLimiter (1)

QueuePolicies\BasePolicy.cs (1)

73if (!_leases.TryDequeue(out var lease))

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\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\Shared\Buffers.MemoryPool\PinnedBlockMemoryPool.cs (3)

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.IIS (3)

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

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

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

Internal\Http2\Http2Connection.cs (2)

1418while (_completedStreams.TryDequeue(out var stream)) 1481while (_streams.Count >= maxStreams && _completedStreams.TryDequeue(out var stream))

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

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

src\Shared\CancellationTokenSourcePool.cs (1)

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

Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.TryDequeue(out _); });

Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)

src\Servers\Kestrel\shared\test\Http3\Http3InMemory.cs (1)

462if (!_streamContextPool.TryDequeue(out var testStreamContext))

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.TryDequeue(out _); });

src\Servers\Kestrel\Transport.Sockets\src\Internal\IOQueue.cs (1)

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

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

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

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

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

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

100if (_blocks.TryDequeue(out var block)) 214while (burstAmount > 0 && _blocks.TryDequeue(out var block)) 246while (_blocks.TryDequeue(out _))

Microsoft.AspNetCore.Server.Kestrel.Transport.Quic.Tests (1)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.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.AspNetCore.WebSockets.Tests (2)

BufferStream.cs (2)

121while (!_bufferedData.TryDequeue(out topBuffer)) 185while (!_bufferedData.TryDequeue(out topBuffer))

Microsoft.Build (14)

AwaitExtensions.cs (1)

178if (_queuedTasks.TryDequeue(out t))

BackEnd\Client\MSBuildClient.cs (1)

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

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

437while (_packetQueue.TryDequeue(out packet))

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

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

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

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

BackEnd\Node\InProcNode.cs (1)

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

BackEnd\Node\OutOfProcNode.cs (1)

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

BackEnd\Node\OutOfProcServerNode.cs (1)

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

Collections\ConcurrentQueueExtensions.cs (1)

22ErrorUtilities.VerifyThrow(stack.TryDequeue(out T result), "Unable to dequeue from queue");

Graph\ParallelWorkSet.cs (1)

195if (_queue.TryDequeue(out Lazy<TResult> workItem))

Instance\TaskFactories\TaskHostTask.cs (1)

312while (_receivedPackets.TryDequeue(out packet))

Logging\ProfilerLogger.cs (1)

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

NodeEndpointOutOfProcBase.cs (1)

726while (localPacketQueue.TryDequeue(out packet))

Microsoft.Build.Tasks.Core (2)

Copy.cs (2)

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

Microsoft.DotNet.Arcade.Sdk.Tests (1)

Utilities\TestProjectFixture.cs (1)

67if (_disposables.TryDequeue(out var disposable))

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));

Microsoft.VisualStudio.LanguageServices (1)

LanguageService\PackageLoadTasks.cs (1)

66while (workTasks.TryDequeue(out var work))

MSBuild (1)

NodeEndpointOutOfProcBase.cs (1)

726while (localPacketQueue.TryDequeue(out packet))

Sockets.BindTests (1)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.TryDequeue(out _); });

Sockets.FunctionalTests (1)

src\Servers\Kestrel\shared\test\TestApplicationErrorLogger.cs (1)

56return new Disposable(() => { Scopes.TryDequeue(out _); });

System.Data.Odbc (1)

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

603while (_pendingOpens.TryDequeue(out next))

System.Net.Sockets (2)

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

294if (eventQueue.TryDequeue(out ev)) 333} while (Environment.TickCount - startTimeMs < 15 && eventQueue.TryDequeue(out ev));

System.Private.CoreLib (11)

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

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

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\libraries\System.Private.CoreLib\src\System\Threading\ThreadPoolWorkQueue.cs (9)

System.Threading.Channels (4)

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\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)

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