new

Projects\ProjectUpdater.cs (2)

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

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

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

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

AppHostAnalyzer.cs (1)

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

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

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

20_scopes = new ConcurrentQueue<BeginScopeContext>(); 21_writes = new ConcurrentQueue<WriteContext>();

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

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

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

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

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

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

xunit\WcfTestCase.cs (1)

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

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

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

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

Circuits\RemoteRenderer.cs (1)

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

Buffering\IncomingRequestLogBuffer.cs (2)

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

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

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

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

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

Logging\TestSink.cs (2)

21_scopes = new ConcurrentQueue<BeginScopeContext>(); 22_writes = new ConcurrentQueue<WriteContext>();

Tracing\CollectingEventListener.cs (1)

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

RecyclableReadOnlySequenceSegment.cs (1)

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

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

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

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

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

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

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

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

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

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

Internal\IOQueue.cs (1)

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

Internal\SocketSenderPool.cs (1)

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

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 (3)

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

Copy.cs (1)

50private static ConcurrentQueue<Action> _copyActionQueue = new ConcurrentQueue<Action>();

GetSDKReferenceFiles.cs (1)

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

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

AddImport\AbstractAddImportFeatureService.cs (1)

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

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

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

Logging\FakeLogCollectorTests.LogEnumeration.cs (1)

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

DefaultHttpClientFactory.cs (1)

88_expiredHandlers = new ConcurrentQueue<ExpiredHandlerTrackingEntry>();

BatchingLoggerProvider.cs (2)

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

DefaultObjectPool.cs (1)

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

Data\ProgressReporter.cs (2)

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

DataLoadSave\Text\BlockingQueue.cs (1)

47_queue = new ConcurrentQueue<T>();

ScopedCss\RewriteCss.cs (1)

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

BlameCollector.cs (1)

140_testSequence = new ConcurrentQueue<Guid>();

TrxLogger.cs (2)

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

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

373_packetQueue = new ConcurrentQueue<INodePacket>();

PackCollectorLogger.cs (1)

35_errors = new ConcurrentQueue<ILogMessage>();

RestoreCommand\Logging\RestoreCollectorLogger.cs (2)

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

Remote\RemoteDependencyWalker.cs (1)

625_toBeProcessedTransitiveCentralPackageVersions = new ConcurrentQueue<LibraryDependency>();

Utility\DedicatedAsynchronousProcessingThread.cs (1)

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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