ConcurrentQueue

3 types derived from ConcurrentQueue

System.Private.CoreLib (1)

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

14internal sealed class MultiProducerMultiConsumerQueue<T> : ConcurrentQueue<T>, IProducerConsumerQueue<T>

System.Threading.Channels (1)

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

14internal sealed class MultiProducerMultiConsumerQueue<T> : ConcurrentQueue<T>, IProducerConsumerQueue<T>

System.Threading.Tasks.Dataflow (1)

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

14internal sealed class MultiProducerMultiConsumerQueue<T> : ConcurrentQueue<T>, IProducerConsumerQueue<T>

123 instantiations of ConcurrentQueue

aspire (2)

Projects\ProjectUpdater.cs (2)

1131public ConcurrentQueue<UpdateStep> UpdateSteps { get; } = new(); 1132public ConcurrentQueue<AnalyzeStep> AnalyzeSteps { get; } = new();

Aspire.Cli.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>(); 28public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 30public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }

Aspire.Confluent.Kafka (3)

ConfluentKafkaMetrics.cs (3)

22public ConcurrentQueue<Measurement<long>> ReplyQueueMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 23public ConcurrentQueue<Measurement<long>> MessageCountMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 24public ConcurrentQueue<Measurement<long>> MessageSizeMeasurements { get; } = new ConcurrentQueue<Measurement<long>>();

Aspire.Dashboard.Components.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

Aspire.Dashboard.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

Aspire.Hosting.Analyzers (1)

AppHostAnalyzer.cs (1)

34var concurrentQueue = new ConcurrentQueue<ConcurrentDictionary<ModelNameOperation, byte>>();

Aspire.Hosting.Testing.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

Aspire.Hosting.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

Aspire.Playground.Tests (4)

tests\Shared\Logging\TestSink.cs (4)

dotnet (1)

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

465var gracefulExceptions = new ConcurrentQueue<GracefulException>();

dotnet-svcutil-lib (1)

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

453private static readonly ConcurrentQueue<StringBuilder> s_freeStringBuilders = new ConcurrentQueue<StringBuilder>();

ILCompiler.ReadyToRun (1)

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

23private ConcurrentQueue<Task<bool>> _tasksThatMustFinish = new ConcurrentQueue<Task<bool>>();

Infrastructure.Common (1)

xunit\WcfTestCase.cs (1)

51ConcurrentQueue<EventWrittenEventArgs> events = new ConcurrentQueue<EventWrittenEventArgs>();

Microsoft.AspNetCore.App.Analyzers (2)

Mvc\MvcAnalyzer.cs (1)

40var concurrentQueue = new ConcurrentQueue<(List<ActionRoute> ActionRoutes, List<AttributeInfo> AuthorizeAttributes)>();

RouteHandlers\RouteHandlerAnalyzer.cs (1)

47var concurrentQueue = new ConcurrentQueue<ConcurrentDictionary<MapOperation, byte>>();

Microsoft.AspNetCore.Components.Endpoints (1)

FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (1)

10public static ConcurrentQueue<TElement> CreateBuffer() => new();

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteRenderer.cs (1)

29internal readonly ConcurrentQueue<UnacknowledgedRenderBatch> _unacknowledgedRenderBatches = new ConcurrentQueue<UnacknowledgedRenderBatch>();

Microsoft.AspNetCore.Diagnostics.Middleware (2)

Buffering\IncomingRequestLogBuffer.cs (2)

32private ConcurrentQueue<SerializedLogRecord> _activeBuffer = new(); 33private ConcurrentQueue<SerializedLogRecord> _standbyBuffer = new();

Microsoft.AspNetCore.Http (1)

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

12private readonly ConcurrentQueue<PooledCancellationTokenSource> _queue = new();

Microsoft.AspNetCore.Http.Extensions (1)

src\aspnetcore\src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (1)

10public static ConcurrentQueue<TElement> CreateBuffer() => new();

Microsoft.AspNetCore.InternalTesting (5)

Logging\TestSink.cs (4)

21_scopes = new ConcurrentQueue<BeginScopeContext>(); 22_writes = new ConcurrentQueue<WriteContext>(); 29public IProducerConsumerCollection<BeginScopeContext> Scopes { get => _scopes; set => _scopes = new ConcurrentQueue<BeginScopeContext>(value); } 31public IProducerConsumerCollection<WriteContext> Writes { get => _writes; set => _writes = new ConcurrentQueue<WriteContext>(value); }

Tracing\CollectingEventListener.cs (1)

13private readonly ConcurrentQueue<EventWrittenEventArgs> _events = new ConcurrentQueue<EventWrittenEventArgs>();

Microsoft.AspNetCore.OutputCaching (1)

RecyclableReadOnlySequenceSegment.cs (1)

40static readonly ConcurrentQueue<RecyclableReadOnlySequenceSegment> s_Spares = new();

Microsoft.AspNetCore.Server.HttpSys (1)

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

Microsoft.AspNetCore.Server.IIS (1)

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

Internal\Http2\Http2Connection.cs (1)

144private readonly ConcurrentQueue<Http2Stream> _completedStreams = new ConcurrentQueue<Http2Stream>();

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

12private readonly ConcurrentQueue<PooledCancellationTokenSource> _queue = new();

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

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

Internal\IOQueue.cs (1)

15private readonly ConcurrentQueue<Work> _workItems = new ConcurrentQueue<Work>();

Internal\SocketSenderPool.cs (1)

13private readonly ConcurrentQueue<SocketSender> _queue = new();

Microsoft.Build (16)

BackEnd\Client\MSBuildClientPacketPump.cs (1)

85ReceivedPacketsQueue = new ConcurrentQueue<INodePacket>();

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

378_packetQueue = new ConcurrentQueue<INodePacket>();

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

275possibleRunningNodes = new ConcurrentQueue<Process>(possibleRunningNodesList); 283ConcurrentQueue<NodeContext> nodeContexts = new(); 284ConcurrentQueue<Exception> exceptions = new(); 1081_packetWriteQueue = new ConcurrentQueue<INodePacket>();

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

1474_eventQueue = new ConcurrentQueue<object>();

BackEnd\Components\RequestBuilder\RequestBuilder.cs (1)

121_pendingResourceRequests = new ConcurrentQueue<Action<ResourceResponse>>();

BackEnd\Node\InProcNode.cs (1)

116_receivedPackets = new ConcurrentQueue<INodePacket>();

BackEnd\Node\OutOfProcNode.cs (1)

146_receivedPackets = new ConcurrentQueue<INodePacket>();

BackEnd\Node\OutOfProcServerNode.cs (1)

107_receivedPackets = new ConcurrentQueue<INodePacket>();

Graph\ParallelWorkSet.cs (1)

34new ConcurrentQueue<WorkItem>();

Instance\TaskFactories\TaskHostTask.cs (1)

205_receivedPackets = new ConcurrentQueue<INodePacket>();

Logging\ProfilerLogger.cs (1)

29private readonly ConcurrentQueue<ProfilerResult> _profiledResults = new ConcurrentQueue<ProfilerResult>();

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

373_packetQueue = new ConcurrentQueue<INodePacket>();

Utilities\AwaitExtensions.cs (1)

158private readonly ConcurrentQueue<Task> _queuedTasks = new ConcurrentQueue<Task>();

Microsoft.Build.Tasks.Core (3)

Copy.cs (2)

50private static ConcurrentQueue<Action> _copyActionQueue = new ConcurrentQueue<Action>(); 637ConcurrentQueue<List<int>> partitionQueue = new ConcurrentQueue<List<int>>(partitionsByDestination.Values);

GetSDKReferenceFiles.cs (1)

59private readonly ConcurrentQueue<string> _exceptions = new ConcurrentQueue<string>();

Microsoft.CodeAnalysis (6)

Diagnostic\DiagnosticBag.cs (1)

305ConcurrentQueue<Diagnostic> newBag = new ConcurrentQueue<Diagnostic>();

Emit\CommonPEModuleBuilder.cs (5)

903Interlocked.CompareExchange(ref NestedTypes, new ConcurrentQueue<Cci.INestedTypeDefinition>(), null); 995Interlocked.CompareExchange(ref defs.Methods, new ConcurrentQueue<Cci.IMethodDefinition>(), null); 1008Interlocked.CompareExchange(ref defs.Properties, new ConcurrentQueue<Cci.IPropertyDefinition>(), null); 1021Interlocked.CompareExchange(ref defs.Fields, new ConcurrentQueue<Cci.IFieldDefinition>(), null); 1043_lazySynthesizedNamespaceMembers.GetOrAdd(container, _ => new ConcurrentQueue<INamespaceOrTypeSymbolInternal>()).Enqueue(typeOrNamespace);

Microsoft.CodeAnalysis.Features (1)

AddImport\AbstractAddImportFeatureService.cs (1)

180var allReferences = new ConcurrentQueue<Reference>();

Microsoft.CodeAnalysis.NetAnalyzers (1)

Microsoft.NetFramework.Analyzers\DoNotUseInsecureDtdProcessingInApiDesign.cs (1)

307var locations = new ConcurrentQueue<Location>();

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

Logging\FakeLogCollectorTests.LogEnumeration.cs (1)

30var eventTracker = new ConcurrentQueue<string>();

Microsoft.Extensions.Http (1)

DefaultHttpClientFactory.cs (1)

88_expiredHandlers = new ConcurrentQueue<ExpiredHandlerTrackingEntry>();

Microsoft.Extensions.Logging.AzureAppServices (2)

BatchingLoggerProvider.cs (2)

158new BlockingCollection<LogMessage>(new ConcurrentQueue<LogMessage>()) : 159new BlockingCollection<LogMessage>(new ConcurrentQueue<LogMessage>(), _queueSize.Value);

Microsoft.Extensions.ObjectPool (1)

DefaultObjectPool.cs (1)

22private protected readonly ConcurrentQueue<T> _items = new();

Microsoft.ML.Core (2)

Data\ProgressReporter.cs (2)

358PendingCheckpoints = new ConcurrentQueue<KeyValuePair<DateTime, ProgressEntry>>(); 369_pendingEvents = new ConcurrentQueue<ProgressEvent>();

Microsoft.ML.Data (1)

DataLoadSave\Text\BlockingQueue.cs (1)

47_queue = new ConcurrentQueue<T>();

Microsoft.ML.FastTree (2)

Training\Applications\ObjectiveFunction.cs (1)

65var queue = new ConcurrentQueue<int>(Enumerable.Range(0, BlockingThreadPool.NumThreads));

Training\WinLossCalculator.cs (1)

55var queue = new ConcurrentQueue<int>(Enumerable.Range(0, BlockingThreadPool.NumThreads));

Microsoft.NET.Sdk.StaticWebAssets.Tasks (1)

ScopedCss\RewriteCss.cs (1)

36var allDiagnostics = new ConcurrentQueue<ErrorMessage>();

Microsoft.TestPlatform.Extensions.BlameDataCollector (1)

BlameCollector.cs (1)

140_testSequence = new ConcurrentQueue<Guid>();

Microsoft.VisualStudio.TestPlatform.Extensions.Trx.TestLogger (2)

TrxLogger.cs (2)

127_runLevelErrorsAndWarnings = new ConcurrentQueue<RunInfo>(); 132_runLevelStdOut = new ConcurrentQueue<string>();

MSBuild (1)

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

373_packetQueue = new ConcurrentQueue<INodePacket>();

NuGet.Commands (3)

PackCollectorLogger.cs (1)

35_errors = new ConcurrentQueue<ILogMessage>();

RestoreCommand\Logging\RestoreCollectorLogger.cs (2)

98_errors = new ConcurrentQueue<IRestoreLogMessage>(); 99_suppressedWarnings = new ConcurrentQueue<IRestoreLogMessage>();

NuGet.DependencyResolver.Core (1)

Remote\RemoteDependencyWalker.cs (1)

625_toBeProcessedTransitiveCentralPackageVersions = new ConcurrentQueue<LibraryDependency>();

NuGet.PackageManagement (2)

IDE\PackageRestoreManager.cs (2)

450var packageReferencesQueue = new ConcurrentQueue<PackageReference>(packageReferences); 507var packageReferencesQueue = new ConcurrentQueue<PackageReference>(packageReferences);

NuGet.Protocol (1)

Utility\DedicatedAsynchronousProcessingThread.cs (1)

23private readonly ConcurrentQueue<Func<Task>> _taskQueue = new ConcurrentQueue<Func<Task>>();

System.Collections.Concurrent (2)

System\Collections\Concurrent\BlockingCollection.cs (2)

147: this(new ConcurrentQueue<T>()) 162: this(new ConcurrentQueue<T>(), boundedCapacity)

System.Data.Odbc (1)

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

111private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();

System.Data.OleDb (1)

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

349private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();

System.Net.Sockets (1)

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

113private readonly ConcurrentQueue<SocketIOEvent> _eventPool = new ConcurrentQueue<SocketIOEvent>();

System.Private.CoreLib (3)

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

426internal readonly WorkQueue workItems = new WorkQueue(); 427internal readonly WorkQueue highPriorityWorkItems = new WorkQueue(); 448_assignableWorkItemQueues[i] = new WorkQueue();

System.ServiceModel.Primitives (1)

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

350private static readonly ConcurrentQueue<StringBuilder> s_freeStringBuilders = new ConcurrentQueue<StringBuilder>();

System.Threading.Channels (1)

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

21private readonly ConcurrentQueue<T> _items = new ConcurrentQueue<T>();

System.Threading.Tasks.Parallel (3)

System\Threading\Tasks\Parallel.cs (2)

279LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); }); 295LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); });

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

22private readonly ConcurrentQueue<Replica> _pendingReplicas = new ConcurrentQueue<Replica>();

System.Transactions.Local (4)

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

32private readonly ConcurrentQueue<NotificationShimBase> _notifications = new(); 34private readonly ConcurrentQueue<ITransactionOptions> _cachedOptions = new(); 35private readonly ConcurrentQueue<ITransactionTransmitter> _cachedTransmitters = new(); 36private readonly ConcurrentQueue<ITransactionReceiver> _cachedReceivers = new();

216 references to ConcurrentQueue

aspire (2)

Projects\ProjectUpdater.cs (2)

1131public ConcurrentQueue<UpdateStep> UpdateSteps { get; } = new(); 1132public ConcurrentQueue<AnalyzeStep> AnalyzeSteps { get; } = new();

Aspire.Cli.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

Aspire.Confluent.Kafka (3)

ConfluentKafkaMetrics.cs (3)

22public ConcurrentQueue<Measurement<long>> ReplyQueueMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 23public ConcurrentQueue<Measurement<long>> MessageCountMeasurements { get; } = new ConcurrentQueue<Measurement<long>>(); 24public ConcurrentQueue<Measurement<long>> MessageSizeMeasurements { get; } = new ConcurrentQueue<Measurement<long>>();

Aspire.Dashboard.Components.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

Aspire.Dashboard.Tests (4)

Integration\StartupTests.cs (2)

875var writes = (ConcurrentQueue<Microsoft.Extensions.Logging.Testing.WriteContext>)testSink.Writes;

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

Aspire.Hosting.Analyzers (1)

AppHostAnalyzer.cs (1)

34var concurrentQueue = new ConcurrentQueue<ConcurrentDictionary<ModelNameOperation, byte>>();

Aspire.Hosting.Testing.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

Aspire.Hosting.Tests (4)

Dcp\TestKubernetesService.cs (2)

24public ConcurrentQueue<CustomResource> CreatedResources { get; } = []; 25public ConcurrentQueue<string> DeletedResources { get; } = [];

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

Aspire.Playground.Tests (2)

tests\Shared\Logging\TestSink.cs (2)

10private ConcurrentQueue<BeginScopeContext> _scopes; 11private ConcurrentQueue<WriteContext> _writes;

dotnet (1)

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

465var gracefulExceptions = new ConcurrentQueue<GracefulException>();

dotnet-svcutil-lib (1)

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

453private static readonly ConcurrentQueue<StringBuilder> s_freeStringBuilders = new ConcurrentQueue<StringBuilder>();

ILCompiler.ReadyToRun (1)

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

23private ConcurrentQueue<Task<bool>> _tasksThatMustFinish = new ConcurrentQueue<Task<bool>>();

Infrastructure.Common (1)

xunit\WcfTestCase.cs (1)

51ConcurrentQueue<EventWrittenEventArgs> events = new ConcurrentQueue<EventWrittenEventArgs>();

Microsoft.AspNetCore.App.Analyzers (2)

Mvc\MvcAnalyzer.cs (1)

40var concurrentQueue = new ConcurrentQueue<(List<ActionRoute> ActionRoutes, List<AttributeInfo> AuthorizeAttributes)>();

RouteHandlers\RouteHandlerAnalyzer.cs (1)

47var concurrentQueue = new ConcurrentQueue<ConcurrentDictionary<MapOperation, byte>>();

Microsoft.AspNetCore.Components.Endpoints (11)

FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (7)

8internal sealed class ConcurrentQueueBufferAdapter<TElement> : ICollectionBufferAdapter<ConcurrentQueue<TElement>, ConcurrentQueue<TElement>, TElement> 10public static ConcurrentQueue<TElement> CreateBuffer() => new(); 12public static ConcurrentQueue<TElement> Add(ref ConcurrentQueue<TElement> buffer, TElement element) 18public static ConcurrentQueue<TElement> ToResult(ConcurrentQueue<TElement> buffer) => buffer;

FormMapping\Factories\Collections\TypedCollectionConverterFactory.cs (4)

53var _ when type == (typeof(ConcurrentQueue<TElement>)) => true, 145var _ when type.IsAssignableTo(typeof(ConcurrentQueue<TElement>)) => 146new CollectionConverter<ConcurrentQueue<TElement>, ConcurrentQueueBufferAdapter<TElement>, ConcurrentQueue<TElement>, TElement>(elementTypeConverter),

Microsoft.AspNetCore.Components.Server (1)

Circuits\RemoteRenderer.cs (1)

29internal readonly ConcurrentQueue<UnacknowledgedRenderBatch> _unacknowledgedRenderBatches = new ConcurrentQueue<UnacknowledgedRenderBatch>();

Microsoft.AspNetCore.Diagnostics.Middleware (3)

Buffering\IncomingRequestLogBuffer.cs (3)

32private ConcurrentQueue<SerializedLogRecord> _activeBuffer = new(); 33private ConcurrentQueue<SerializedLogRecord> _standbyBuffer = new(); 103ConcurrentQueue<SerializedLogRecord> tempBuffer;

Microsoft.AspNetCore.Http (1)

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

12private readonly ConcurrentQueue<PooledCancellationTokenSource> _queue = new();

Microsoft.AspNetCore.Http.Extensions (11)

src\aspnetcore\src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\ConcurrentQueueBufferAdapter.cs (7)

src\aspnetcore\src\Components\Endpoints\src\FormMapping\Factories\Collections\TypedCollectionConverterFactory.cs (4)

Microsoft.AspNetCore.InternalTesting (3)

Logging\TestSink.cs (2)

11private ConcurrentQueue<BeginScopeContext> _scopes; 12private ConcurrentQueue<WriteContext> _writes;

Tracing\CollectingEventListener.cs (1)

13private readonly ConcurrentQueue<EventWrittenEventArgs> _events = new ConcurrentQueue<EventWrittenEventArgs>();

Microsoft.AspNetCore.OutputCaching (1)

RecyclableReadOnlySequenceSegment.cs (1)

40static readonly ConcurrentQueue<RecyclableReadOnlySequenceSegment> s_Spares = new();

Microsoft.AspNetCore.Server.HttpSys (1)

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

Microsoft.AspNetCore.Server.IIS (1)

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

Internal\Http2\Http2Connection.cs (1)

144private readonly ConcurrentQueue<Http2Stream> _completedStreams = new ConcurrentQueue<Http2Stream>();

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

12private readonly ConcurrentQueue<PooledCancellationTokenSource> _queue = new();

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

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

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

44private readonly ConcurrentQueue<MemoryPoolBlock> _blocks = new ConcurrentQueue<MemoryPoolBlock>();

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

Internal\IOQueue.cs (1)

15private readonly ConcurrentQueue<Work> _workItems = new ConcurrentQueue<Work>();

Internal\SocketSenderPool.cs (1)

13private readonly ConcurrentQueue<SocketSender> _queue = new();

Microsoft.Build (21)

BackEnd\Client\MSBuildClientPacketPump.cs (1)

23public ConcurrentQueue<INodePacket> ReceivedPacketsQueue { get; }

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

92private ConcurrentQueue<INodePacket> _packetQueue;

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

266ConcurrentQueue<Process> possibleRunningNodes = null; 283ConcurrentQueue<NodeContext> nodeContexts = new(); 284ConcurrentQueue<Exception> exceptions = new(); 989private readonly ConcurrentQueue<INodePacket> _packetWriteQueue;

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

262private ConcurrentQueue<object> _eventQueue; 1358ConcurrentQueue<object> eventQueue = _eventQueue; 1493var eventQueue = _eventQueue;

BackEnd\Components\RequestBuilder\RequestBuilder.cs (1)

62private ConcurrentQueue<Action<ResourceResponse>> _pendingResourceRequests;

BackEnd\Node\InProcNode.cs (1)

54private readonly ConcurrentQueue<INodePacket> _receivedPackets;

BackEnd\Node\OutOfProcNode.cs (1)

107private readonly ConcurrentQueue<INodePacket> _receivedPackets;

BackEnd\Node\OutOfProcServerNode.cs (1)

67private readonly ConcurrentQueue<INodePacket> _receivedPackets;

Collections\ConcurrentQueueExtensions.cs (1)

19public static T Dequeue<T>(this ConcurrentQueue<T> stack) where T : class

Graph\ParallelWorkSet.cs (1)

33private readonly ConcurrentQueue<WorkItem> _queue =

Instance\TaskFactories\TaskHostTask.cs (1)

72private ConcurrentQueue<INodePacket> _receivedPackets;

Logging\ProfilerLogger.cs (1)

29private readonly ConcurrentQueue<ProfilerResult> _profiledResults = new ConcurrentQueue<ProfilerResult>();

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

106private ConcurrentQueue<INodePacket> _packetQueue; 389ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 661ConcurrentQueue<INodePacket> localPacketQueue,

Utilities\AwaitExtensions.cs (1)

158private readonly ConcurrentQueue<Task> _queuedTasks = new ConcurrentQueue<Task>();

Microsoft.Build.Tasks.Core (5)

Copy.cs (2)

50private static ConcurrentQueue<Action> _copyActionQueue = new ConcurrentQueue<Action>(); 637ConcurrentQueue<List<int>> partitionQueue = new ConcurrentQueue<List<int>>(partitionsByDestination.Values);

GetSDKReferenceFiles.cs (3)

59private readonly ConcurrentQueue<string> _exceptions = new ConcurrentQueue<string>(); 888private readonly ConcurrentQueue<string> _exceptionMessages; 913internal SDKFilesCache(ConcurrentQueue<string> exceptionQueue, string cacheFileDirectory, GetAssemblyName getAssemblyName, GetAssemblyRuntimeVersion getRuntimeVersion, FileExists fileExists)

Microsoft.CodeAnalysis (19)

Diagnostic\DiagnosticBag.cs (13)

Emit\CommonPEModuleBuilder.cs (6)

880private ConcurrentQueue<Cci.INestedTypeDefinition> NestedTypes; 881public ConcurrentQueue<Cci.IMethodDefinition> Methods; 882public ConcurrentQueue<Cci.IPropertyDefinition> Properties; 883public ConcurrentQueue<Cci.IFieldDefinition> Fields; 952private ConcurrentDictionary<INamespaceSymbolInternal, ConcurrentQueue<INamespaceOrTypeSymbolInternal>> _lazySynthesizedNamespaceMembers; 1040Interlocked.CompareExchange(ref _lazySynthesizedNamespaceMembers, new ConcurrentDictionary<INamespaceSymbolInternal, ConcurrentQueue<INamespaceOrTypeSymbolInternal>>(), null);

Microsoft.CodeAnalysis.Features (10)

AddImport\AbstractAddImportFeatureService.cs (6)

180var allReferences = new ConcurrentQueue<Reference>(); 209ConcurrentQueue<Reference> allSymbolReferences, SymbolReferenceFinder finder, bool exact, CancellationToken cancellationToken) 218Project project, ConcurrentQueue<Reference> allSymbolReferences, int maxResults, 263Project project, ConcurrentQueue<Reference> allSymbolReferences, int maxResults, SymbolReferenceFinder finder, 351ConcurrentQueue<Reference> allSymbolReferences, 476private static void AddRange(ConcurrentQueue<Reference> allSymbolReferences, ImmutableArray<SymbolReference> proposedReferences)

AddImport\SymbolReferenceFinder_PackageAssemblySearch.cs (4)

22ConcurrentQueue<Reference> allReferences, bool exact, CancellationToken cancellationToken) 125ConcurrentQueue<Reference> allReferences, 154ConcurrentQueue<Reference> allReferences, 182ConcurrentQueue<Reference> allReferences,

Microsoft.CodeAnalysis.NetAnalyzers (1)

Microsoft.NetFramework.Analyzers\DoNotUseInsecureDtdProcessingInApiDesign.cs (1)

307var locations = new ConcurrentQueue<Location>();

Microsoft.CodeAnalysis.VisualBasic (1)

Compilation\VisualBasicCompilation.vb (1)

113Private _lazyImportInfos As ConcurrentQueue(Of ImportInfo)

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

Logging\FakeLogCollectorTests.LogEnumeration.cs (4)

30var eventTracker = new ConcurrentQueue<string>(); 163ConcurrentQueue<string>? eventTracker, 211private static void OutputEventTracker(ITestOutputHelper testOutputHelper, ConcurrentQueue<string> eventTracker) 222ConcurrentQueue<string>? eventTracker)

Microsoft.Extensions.Http (1)

DefaultHttpClientFactory.cs (1)

59internal readonly ConcurrentQueue<ExpiredHandlerTrackingEntry> _expiredHandlers;

Microsoft.Extensions.ObjectPool (1)

DefaultObjectPool.cs (1)

22private protected readonly ConcurrentQueue<T> _items = new();

Microsoft.ML.Core (2)

Data\ProgressReporter.cs (2)

298private readonly ConcurrentQueue<ProgressEvent> _pendingEvents; 343public readonly ConcurrentQueue<KeyValuePair<DateTime, ProgressEntry>> PendingCheckpoints;

Microsoft.ML.Data (1)

DataLoadSave\Text\BlockingQueue.cs (1)

35private readonly ConcurrentQueue<T> _queue;

Microsoft.ML.FastTree (2)

Training\Applications\ObjectiveFunction.cs (1)

65var queue = new ConcurrentQueue<int>(Enumerable.Range(0, BlockingThreadPool.NumThreads));

Training\WinLossCalculator.cs (1)

55var queue = new ConcurrentQueue<int>(Enumerable.Range(0, BlockingThreadPool.NumThreads));

Microsoft.NET.Sdk.StaticWebAssets.Tasks (1)

ScopedCss\RewriteCss.cs (1)

36var allDiagnostics = new ConcurrentQueue<ErrorMessage>();

Microsoft.TestPlatform.Extensions.BlameDataCollector (1)

BlameCollector.cs (1)

42private ConcurrentQueue<Guid>? _testSequence;

Microsoft.VisualStudio.TestPlatform.Extensions.Trx.TestLogger (2)

TrxLogger.cs (2)

78private ConcurrentQueue<string>? _runLevelStdOut; 82private ConcurrentQueue<RunInfo>? _runLevelErrorsAndWarnings;

MSBuild (3)

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

106private ConcurrentQueue<INodePacket> _packetQueue; 389ConcurrentQueue<INodePacket> localPacketQueue = _packetQueue; 661ConcurrentQueue<INodePacket> localPacketQueue,

mscorlib (1)

src\runtime\src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

78[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentQueue<>))]

netstandard (1)

netstandard.cs (1)

96[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentQueue<>))]

NuGet.Commands (3)

PackCollectorLogger.cs (1)

16private readonly ConcurrentQueue<ILogMessage> _errors;

RestoreCommand\Logging\RestoreCollectorLogger.cs (2)

20private readonly ConcurrentQueue<IRestoreLogMessage> _errors; 21private readonly ConcurrentQueue<IRestoreLogMessage> _suppressedWarnings;

NuGet.DependencyResolver.Core (1)

Remote\RemoteDependencyWalker.cs (1)

620private ConcurrentQueue<LibraryDependency> _toBeProcessedTransitiveCentralPackageVersions;

NuGet.PackageManagement (4)

IDE\PackageRestoreManager.cs (4)

450var packageReferencesQueue = new ConcurrentQueue<PackageReference>(packageReferences); 470ConcurrentQueue<PackageReference> packageReferencesQueue, 507var packageReferencesQueue = new ConcurrentQueue<PackageReference>(packageReferences); 580private static async Task CopySatelliteFilesRunnerAsync(ConcurrentQueue<PackageReference> packageReferencesQueue,

NuGet.Protocol (1)

Utility\DedicatedAsynchronousProcessingThread.cs (1)

23private readonly ConcurrentQueue<Func<Task>> _taskQueue = new ConcurrentQueue<Func<Task>>();

System.Collections.Concurrent (3)

src\runtime\artifacts\obj\System.Collections.Concurrent\Release\net11.0\System.Collections.Concurrent.Forwards.cs (1)

4[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentQueue<>))]

System\Collections\Concurrent\BlockingCollection.cs (2)

144/// The default underlying collection is a <see cref="System.Collections.Concurrent.ConcurrentQueue{T}">ConcurrentQueue<T></see>. 159/// The default underlying collection is a <see cref="System.Collections.Concurrent.ConcurrentQueue{T}">ConcurrentQueue<T></see>.

System.Data.Odbc (1)

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

111private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();

System.Data.OleDb (1)

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

349private readonly ConcurrentQueue<PendingGetConnection> _pendingOpens = new ConcurrentQueue<PendingGetConnection>();

System.Net.Sockets (3)

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

113private readonly ConcurrentQueue<SocketIOEvent> _eventPool = new ConcurrentQueue<SocketIOEvent>(); 371private readonly ConcurrentQueue<SocketIOEvent> _pool; 384public SocketIOEvent(ConcurrentQueue<SocketIOEvent> pool)

System.Private.CoreLib (39)

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

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

16/// These segments are linked together to form the unbounded <see cref="ConcurrentQueue{T}"/>.

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

36/// -or- The number of elements in the source <see cref="ConcurrentQueue{T}"/> is greater than the

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

16using WorkQueue = System.Collections.Concurrent.ConcurrentQueue<object>; 426internal readonly WorkQueue workItems = new WorkQueue(); 427internal readonly WorkQueue highPriorityWorkItems = new WorkQueue(); 437internal readonly WorkQueue[] _assignableWorkItemQueues = 438new WorkQueue[s_assignableWorkItemQueueCount]; 561WorkQueue queue = tl.assignedGlobalWorkItemQueue; 632WorkQueue queue = 1129public WorkQueue assignedGlobalWorkItemQueue; 1673foreach (WorkQueue queue in s_workQueue._assignableWorkItemQueues)

System.ServiceModel.Primitives (1)

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

350private static readonly ConcurrentQueue<StringBuilder> s_freeStringBuilders = new ConcurrentQueue<StringBuilder>();

System.Text.Json (3)

System\Text\Json\Serialization\Converters\Collection\ConcurrentQueueOfTConverter.cs (1)

11where TCollection : ConcurrentQueue<TElement>

System\Text\Json\Serialization\Converters\Collection\IEnumerableConverterFactory.cs (1)

144else if ((actualTypeToConvert = typeToConvert.GetCompatibleGenericBaseClass(typeof(ConcurrentQueue<>))) != null)

System\Text\Json\Serialization\Metadata\JsonMetadataServices.Collections.cs (1)

318where TCollection : ConcurrentQueue<TElement>

System.Text.Json.SourceGeneration (1)

Helpers\KnownTypeSymbols.cs (1)

67public INamedTypeSymbol? ConcurrentQueueType => GetOrResolveType(typeof(ConcurrentQueue<>), ref _ConcurrentQueueType);

System.Threading.Channels (1)

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

21private readonly ConcurrentQueue<T> _items = new ConcurrentQueue<T>();

System.Threading.Tasks.Parallel (5)

System\Threading\Tasks\Parallel.cs (3)

250ConcurrentQueue<Exception>? exceptionQ = null; // will be lazily initialized if necessary 279LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); }); 295LazyInitializer.EnsureInitialized<ConcurrentQueue<Exception>>(ref exceptionQ, () => { return new ConcurrentQueue<Exception>(); });

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

22private readonly ConcurrentQueue<Replica> _pendingReplicas = new ConcurrentQueue<Replica>(); 23private ConcurrentQueue<Exception>? _exceptions;

System.Transactions.Local (4)

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

32private readonly ConcurrentQueue<NotificationShimBase> _notifications = new(); 34private readonly ConcurrentQueue<ITransactionOptions> _cachedOptions = new(); 35private readonly ConcurrentQueue<ITransactionTransmitter> _cachedTransmitters = new(); 36private readonly ConcurrentQueue<ITransactionReceiver> _cachedReceivers = new();