ConcurrentQueue

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

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

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

xunit\WcfTestCase.cs (1)

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

EventSourceTests.cs (1)

423private readonly ConcurrentQueue<EventSnapshot> _events = new ConcurrentQueue<EventSnapshot>();

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

77internal readonly ConcurrentQueue<TestStreamContext> _streamContextPool = new ConcurrentQueue<TestStreamContext>();

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

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

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

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

RendererTest.cs (4)

237var log = new ConcurrentQueue<(int id, NestedAsyncComponent.EventType @event)>(); 396var log = new ConcurrentQueue<(int id, NestedAsyncComponent.EventType @event)>(); 440var log = new ConcurrentQueue<(int id, NestedAsyncComponent.EventType @event)>(); 484var log = new ConcurrentQueue<(int id, NestedAsyncComponent.EventType @event)>();

QueuePolicies\BasePolicy.cs (1)

15private readonly ConcurrentQueue<RateLimitLease> _leases = new ConcurrentQueue<RateLimitLease>();

Buffering\IncomingRequestLogBuffer.cs (2)

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

src\Shared\CancellationTokenSourcePool.cs (1)

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

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

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

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

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

Internal\Http2\Http2Connection.cs (1)

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

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

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

src\Shared\CancellationTokenSourcePool.cs (1)

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

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

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

77internal readonly ConcurrentQueue<TestStreamContext> _streamContextPool = new ConcurrentQueue<TestStreamContext>();

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

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

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

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

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

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

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

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

Internal\IOQueue.cs (1)

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

Internal\SocketSenderPool.cs (1)

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

Docker.cs (1)

211var lines = new ConcurrentQueue<string>();

src\Shared\SignalR\LogSinkProvider.cs (1)

17private readonly ConcurrentQueue<LogRecord> _logs = new ConcurrentQueue<LogRecord>();

WebApplicationTests.cs (1)

3045private ConcurrentQueue<EventWrittenEventArgs> _events = new ConcurrentQueue<EventWrittenEventArgs>();

WebHostTests.cs (1)

131private ConcurrentQueue<EventWrittenEventArgs> _events = new ConcurrentQueue<EventWrittenEventArgs>();

BufferStream.cs (1)

28_bufferedData = new ConcurrentQueue<byte[]>();

AwaitExtensions.cs (1)

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

BackEnd\Client\MSBuildClientPacketPump.cs (1)

86ReceivedPacketsQueue = new ConcurrentQueue<INodePacket>();

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

371_packetQueue = new ConcurrentQueue<INodePacket>();

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

239ConcurrentQueue<NodeContext> nodeContexts = new(); 240ConcurrentQueue<Exception> exceptions = new(); 650_packetWriteQueue = new ConcurrentQueue<INodePacket>();

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

1352_eventQueue = new ConcurrentQueue<object>();

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

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

BackEnd\Node\InProcNode.cs (1)

113_receivedPackets = new ConcurrentQueue<INodePacket>();

BackEnd\Node\OutOfProcNode.cs (1)

143_receivedPackets = new ConcurrentQueue<INodePacket>();

BackEnd\Node\OutOfProcServerNode.cs (1)

82_receivedPackets = new ConcurrentQueue<INodePacket>();

Graph\ParallelWorkSet.cs (1)

34new ConcurrentQueue<Lazy<TResult>>();

Instance\TaskFactories\TaskHostTask.cs (1)

162_receivedPackets = new ConcurrentQueue<INodePacket>();

Logging\ProfilerLogger.cs (1)

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

NodeEndpointOutOfProcBase.cs (1)

353_packetQueue = new ConcurrentQueue<INodePacket>();

ProjectCache\ProjectCacheTests.cs (2)

266public ConcurrentQueue<BuildRequestData> Requests { get; } = new(); 272public ConcurrentQueue<int> QueryStartStops = new();

Copy.cs (1)

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

GetSDKReferenceFiles.cs (1)

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

MockEngine.cs (2)

43private readonly ConcurrentQueue<BuildErrorEventArgs> _errorEvents = new ConcurrentQueue<BuildErrorEventArgs>(); 44private readonly ConcurrentQueue<BuildWarningEventArgs> _warningEvents = new ConcurrentQueue<BuildWarningEventArgs>();

Diagnostic\DiagnosticBag.cs (1)

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

Emit\CommonPEModuleBuilder.cs (5)

886Interlocked.CompareExchange(ref NestedTypes, new ConcurrentQueue<Cci.INestedTypeDefinition>(), null); 978Interlocked.CompareExchange(ref defs.Methods, new ConcurrentQueue<Cci.IMethodDefinition>(), null); 991Interlocked.CompareExchange(ref defs.Properties, new ConcurrentQueue<Cci.IPropertyDefinition>(), null); 1004Interlocked.CompareExchange(ref defs.Fields, new ConcurrentQueue<Cci.IFieldDefinition>(), null); 1026_lazySynthesizedNamespaceMembers.GetOrAdd(container, _ => new ConcurrentQueue<INamespaceOrTypeSymbolInternal>()).Enqueue(typeOrNamespace);

Semantics\ExtensionTests.cs (4)

43917public ConcurrentQueue<string> _results = new ConcurrentQueue<string>(); 43988public ConcurrentQueue<string> _results = new ConcurrentQueue<string>(); 44036public ConcurrentQueue<string> _results = new ConcurrentQueue<string>(); 44088public ConcurrentQueue<string> _results = new ConcurrentQueue<string>();

ObjectFormatterTests.cs (1)

699var obj = new ConcurrentQueue<object>();

Compilation\CompilationAPITests.cs (2)

544var queue = new ConcurrentQueue<MetadataReference> { }; 871var queue = new ConcurrentQueue<SyntaxTree> { };

AddImport\AbstractAddImportFeatureService.cs (1)

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

Diagnostics\TrackingDiagnosticAnalyzer.cs (1)

50private readonly ConcurrentQueue<Entry> _callLog = new ConcurrentQueue<Entry>();

Utilities\TestProjectFixture.cs (1)

21private readonly ConcurrentQueue<IDisposable> _disposables = new ConcurrentQueue<IDisposable>();

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

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

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

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

NodeEndpointOutOfProcBase.cs (1)

353_packetQueue = new ConcurrentQueue<INodePacket>();

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

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

29public ConcurrentQueue<LogMessage> Messages { get; } = new ConcurrentQueue<LogMessage>(); 31public ConcurrentQueue<object> Scopes { get; } = new ConcurrentQueue<object>();

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\Net\Sockets\SocketAsyncEngine.Unix.cs (1)

92private readonly ConcurrentQueue<SocketIOEvent> _eventQueue = new ConcurrentQueue<SocketIOEvent>();

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

416internal readonly WorkQueue workItems = new WorkQueue(); 417internal readonly WorkQueue highPriorityWorkItems = new WorkQueue(); 421s_prioritizationExperiment ? new WorkQueue() : null!; 468_assignableWorkItemQueues[i] = new WorkQueue();

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

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

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

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

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

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