Queue

src\RoslynAnalyzers\Utilities\FlowAnalysis\FlowAnalysis\Analysis\GlobalFlowStateAnalysis\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

152var currentNodes = new Queue<GlobalFlowStateAnalysisValueSet>();

Microsoft.CodeAnalysis.BannedApiAnalyzers (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

Microsoft.CodeAnalysis.CSharp.Scripting.UnitTests (1)

ObjectFormatterTests.cs (1)

559var obj = new Queue<int>();

Microsoft.CodeAnalysis.CSharp.Symbol.UnitTests (1)

Symbols\CorLibrary\CorTypes.cs (1)

111Queue<NamespaceSymbol> namespaces = new Queue<NamespaceSymbol>();

Microsoft.CodeAnalysis.EditorFeatures (1)

IntelliSense\ViewTextSpan.cs (1)

109var sourceSpans = new Queue<SnapshotSpan>(start.MapToSourceSnapshots(span));

Microsoft.CodeAnalysis.ExpressionEvaluator.ResultProvider.Utilities (1)

Debugger\Engine\DkmWorkList.cs (1)

30_workList = new Queue<Action>(1);

Microsoft.CodeAnalysis.Features (1)

Shared\Utilities\ExtractTypeHelpers.cs (1)

142var unanalyzedTypeParameters = new Queue<ITypeParameterSymbol>(directlyReferencedTypeParameters);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

Microsoft.CodeAnalysis.PublicApiAnalyzers (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

Microsoft.CodeAnalysis.Test.Utilities (1)

CompilationVerifier.cs (1)

992var toVisit = new Queue<Compilation>(findDirectReferencedCompilations(original));

Microsoft.CodeAnalysis.UnitTests (1)

Collections\List\TestBase.Generic.cs (1)

136Queue<T> queue = new Queue<T>(count);

Microsoft.CodeAnalysis.VisualBasic (3)

Binding\Binder_Lookup.vb (3)

1460Dim lookIn As New Queue(Of InterfaceInfo) 1702allInterfaces = New Queue(Of InterfaceInfo) 1996Dim lookIn As New Queue(Of InterfaceInfo)

Microsoft.CodeAnalysis.Workspaces (1)

Differencing\EditScript.cs (1)

50var queue = new Queue<IEnumerable<TNode>>();

Microsoft.DotNet.Build.Tasks.Packaging (1)

CreateTrimDependencyGroups.cs (1)

85var newDependencyGroups = new Queue<TaskItemPackageDependencyGroup>();

Microsoft.Extensions.AI (1)

ChatReduction\MessageCountingChatReducer.cs (1)

48Queue<ChatMessage> reducedMessages = new(capacity: _targetCount);

Microsoft.Extensions.AI.Abstractions.Tests (1)

test\Shared\JsonSchemaExporter\TestTypes.cs (1)

817yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}""");

Microsoft.Extensions.Http.Diagnostics (1)

Http\DownstreamDependencyMetadataManager.cs (1)

195Queue<RequestMetadataTrieNode> queue = new();

Microsoft.Extensions.Http.Resilience.Tests (1)

Hedging\HedgingTests.cs (1)

37private readonly Queue<HttpResponseMessage> _responses = new();

Microsoft.Extensions.Logging.Console (1)

ConsoleLoggerProcessor.cs (1)

65_messageQueue = new Queue<LogMessageEntry>();

Microsoft.Maui.Controls (6)

BindableObject.cs (1)

583 context.DelayedSetters = delayQueue = new Queue<SetValueArgs>();

Element\Element.cs (2)

700 var queue = new Queue<Element>(16); 806 var queue = new Queue<Element>(16);

LockingSemaphore.cs (1)

12 readonly Queue<TaskCompletionSource<bool>> _waiters = new Queue<TaskCompletionSource<bool>>();

StyleSheets\CssReader.cs (1)

20 readonly Queue<char> _cache = new Queue<char>();

TemplateUtilities.cs (1)

87 var queue = new Queue<Element>(16);

Microsoft.Maui.Essentials (1)

Compass\LowPassFilter.shared.cs (1)

10 readonly Queue<float> history = new Queue<float>(length);

Microsoft.ML.AutoML (2)

Tuner\SmacTuner.cs (2)

76_candidates = new Queue<Parameter>(); 107_candidates = new Queue<Parameter>(GenerateCandidateConfigurations(_fitModelEveryNTrials, _histories, model));

Microsoft.ML.Core (2)

Data\Repository.cs (1)

307_closed = new Queue<KeyValuePair<string, Stream>>();

Utilities\ThreadUtils.cs (1)

35private static readonly Queue<(Delegate, object, TaskCompletionSource<bool>)> _queue = new Queue<(Delegate, object, TaskCompletionSource<bool>)>();

Microsoft.ML.Core.Tests (1)

UnitTests\TestHosts.cs (1)

56Queue<IHost> queue = new Queue<IHost>();

Microsoft.ML.FastTree (2)

Training\EarlyStoppingCriteria.cs (2)

214PastScores = new Queue<float>(windowSize); 225PastScores = new Queue<float>(windowSize);

Microsoft.ML.StandardTrainers (1)

Optimizer\OptimizationMonitor.cs (1)

227_pastValues = new Queue<float>(n);

Microsoft.ML.Sweeper (1)

Algorithms\NelderMead.cs (1)

122_pendingSweepsNotSubmitted = new Queue<KeyValuePair<ParameterSet, float[]>>();

Microsoft.ML.Transforms (1)

Expression\Lexer.cs (1)

63_queue = new Queue<Token>(4);

Microsoft.VisualStudio.LanguageServices (3)

CommonControls\MemberSelectionViewModel.cs (1)

168var queue = new Queue<ISymbol>();

MoveStaticMembers\StaticMemberSelectionViewModel.cs (1)

85var queue = new Queue<ISymbol>();

PullMemberUp\MainDialog\BaseTypeTreeNodeViewModel.cs (1)

50var queue = new Queue<BaseTypeTreeNodeViewModel>();

Microsoft.VisualStudio.LanguageServices.Implementation (1)

CodeModel\AbstractCodeModelService.AbstractCodeModelEventCollector.cs (1)

36var queue = new Queue<CodeModelEvent>();

PresentationCore (4)

System\Windows\Input\Stylus\Common\DynamicRenderer.cs (1)

1207private Queue<StrokeInfo> _renderCompleteDRThreadStrokeInfoList = new Queue<StrokeInfo>();

System\Windows\Input\Stylus\Wisp\WispLogic.cs (1)

3676private Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();

System\Windows\Media\Animation\TimeManager.cs (1)

58_eventQueue = new Queue<WeakReference>();

System\Windows\Media\ChannelManager.cs (1)

126_freeSyncChannels = new Queue<DUCE.Channel>(3);

PresentationFramework (3)

MS\Internal\Data\DataBindEngine.cs (1)

709private Queue<DataBindOperation> _crossThreadQueue = new Queue<DataBindOperation>();

System\Windows\Controls\ItemContainerGenerator.cs (2)

485_recyclableContainers = new Queue<DependencyObject>(); 2797private Queue<DependencyObject> _recyclableContainers = new Queue<DependencyObject>();

Roslyn.Diagnostics.Analyzers (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

RunTests (1)

ProcessUtil.cs (1)

72var toVisit = new Queue<Process>();

Shared.Tests (2)

JsonSchemaExporter\TestTypes.cs (1)

817yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}""");

Throw\ThrowTest.cs (1)

351var queue = new Queue<int>();

System.CodeDom (1)

src\libraries\Common\src\System\CodeDom\CodeTypeReference.cs (1)

141var q = new Queue<int>();

System.Collections (2)

System\Collections\Generic\SortedSet.cs (1)

237var processQueue = new Queue<Node>();

System\Collections\Generic\SortedSet.TreeSubSet.cs (1)

253Queue<Node> processQueue = new Queue<Node>();

System.ComponentModel.Composition (2)

System\ComponentModel\Composition\ContractNameServices.cs (2)

120Queue<Type> genericTypeArguments = new Queue<Type>(type.GetGenericArguments()); 295Queue<Type> typeArguments = new Queue<Type>(types);

System.Composition.Hosting (1)

System\Composition\Hosting\Core\UpdateResult.cs (1)

22_remainingProviders = new Queue<ExportDescriptorProvider>(providers);

System.Diagnostics.Process (2)

System\Diagnostics\AsyncStreamReader.cs (1)

64_messageQueue = new Queue<string?>();

System\Diagnostics\Process.NonUap.cs (1)

44var descendantProcesses = new Queue<Process>();

System.IO.Ports (2)

System\IO\Ports\SerialStream.Unix.cs (2)

38private readonly Queue<SerialStreamIORequest> _readQueue = new(); 40private readonly Queue<SerialStreamIORequest> _writeQueue = new();

System.Linq (3)

System\Linq\ElementAt.cs (1)

160Queue<TSource> queue = new();

System\Linq\Take.cs (2)

119queue = new Queue<TSource>(); 169queue = new Queue<TSource>();

System.Linq.AsyncEnumerable (3)

System\Linq\ElementAtAsync.cs (1)

147Queue<TSource> queue = new();

System\Linq\Take.cs (2)

148queue = new Queue<TSource>(); 200queue = new Queue<TSource>();

System.Linq.Expressions (1)

System\Linq\Expressions\DebugViewWriter.cs (1)

402_lambdas ??= new Queue<LambdaExpression>();

System.Linq.Parallel (3)

System\Linq\Parallel\Channels\SynchronousChannel.cs (1)

48_queue = new Queue<T>();

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (1)

444_mergeHelper._buffers[producer] = new Queue<Pair<TKey, TOutput>>(INITIAL_BUFFER_SIZE);

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)

164buffers[i] = new Queue<Pair<TKey, TOutput>>(OrderPreservingPipeliningMergeHelper<TOutput, TKey>.INITIAL_BUFFER_SIZE);

System.Private.CoreLib (2)

src\libraries\System.Private.CoreLib\src\System\IO\Enumeration\FileSystemEnumerator.Unix.cs (1)

144_pending ??= new Queue<(string Path, int RemainingDepth)>();

src\libraries\System.Private.CoreLib\src\System\SearchValues\Strings\Helpers\AhoCorasickBuilder.cs (1)

138var queue = new Queue<(char Char, int Index)>();

System.Private.DataContractSerialization (3)

src\libraries\Common\src\System\CodeDom\CodeTypeReference.cs (1)

141var q = new Queue<int>();

System\Runtime\Serialization\DataContract.cs (1)

1160Queue<Type> itemTypeQueue = new Queue<Type>();

System\Runtime\Serialization\ExtensionDataReader.cs (1)

507_deserializedDataNodes ??= new Queue<IDataNode>();

System.Private.Windows.Core (1)

System\Private\Windows\BinaryFormat\Deserializer\Deserializer.cs (1)

274_pendingSerializationInfo ??= new();

System.Private.Xml (2)

System\Xml\Schema\ContentValidator.cs (1)

1451var unmarked = new Queue<BitSet>();

System\Xml\Serialization\CodeGenerator.cs (1)

1622freeLocalQueue = new Queue<LocalBuilder>();

System.Resources.Extensions (1)

System\Resources\Extensions\BinaryFormat\Deserializer\Deserializer.cs (1)

279_pendingSerializationInfo ??= new();

System.ServiceModel.Primitives (10)

Internals\System\Runtime\InputQueue.cs (1)

29_readerQueue = new Queue<IQueueReader>();

System\ServiceModel\Channels\CommunicationObject.cs (1)

1077private Queue<Exception> _exceptions = new Queue<Exception>();

System\ServiceModel\Channels\QueuedObjectPool.cs (1)

46_objectQueue = new Queue<T>(batchAllocCount);

System\ServiceModel\Channels\ReliableChannelBinder.cs (2)

1085_getChannelQueue = new Queue<IWaiter>(); 1094_waitQueue = new Queue<IWaiter>();

System\ServiceModel\Channels\ServiceChannel.cs (1)

2040_queue = new Queue<IWaiter>();

System\ServiceModel\Channels\TransmissionStrategy.cs (2)

63private readonly Queue<IQueueAdder> _waitQueue = new Queue<IQueueAdder>(); 264adders = new Queue<IQueueAdder>(count);

System\ServiceModel\Dispatcher\ConcurrencyBehavior.cs (2)

268_newMessageQueue = new Queue<ConcurrencyBehavior.IWaiter>(); 278_calloutMessageQueue = new Queue<ConcurrencyBehavior.IWaiter>();

System.Text.Json (2)

src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)

116var childlessQueue = new Queue<int>(); // the queue of nodes without children or whose children have been visited

System\Text\Json\ValueQueue.cs (1)

34(_multiple ??= new()).Enqueue(_single!);

System.Text.Json.SourceGeneration (2)

JsonSourceGenerator.Parser.cs (1)

45private readonly Queue<TypeToGenerate> _typesToGenerate = new();

src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)

116var childlessQueue = new Queue<int>(); // the queue of nodes without children or whose children have been visited

System.Text.RegularExpressions (1)

System\Text\RegularExpressions\Symbolic\SymbolicRegexMatcher.Explore.cs (1)

22Queue<MatchingState<TSet>> toExplore = new();

System.Threading.Tasks.Dataflow (3)

Blocks\BatchBlock.cs (1)

241private readonly Queue<T> _messages = new Queue<T>();

Blocks\BroadcastBlock.cs (1)

496private readonly Queue<TOutput> _messages = new Queue<TOutput>();

Blocks\JoinBlock.cs (1)

508if (dbo.Greedy) _messages = new Queue<T>();

System.Windows.Forms (3)

System\Windows\Forms\Control.cs (1)

6526_threadCallbackList ??= new Queue<ThreadMethodEntry>();

System\Windows\Forms\Dialogs\TaskDialog\TaskDialog.cs (1)

78private readonly Queue<TaskDialogPage> _waitingNavigationPages = new();

System\Windows\Forms\SendKeys\SendKeys.cs (1)

86private static readonly Queue<SKEvent> s_events = new();

System.Xaml (5)

System\Xaml\Context\NameFixupGraph.cs (1)

45_resolvedTokensPendingProcessing = new Queue<NameFixupToken>();

System\Xaml\Parser\NodeStreamSorter.cs (1)

96_buffer = new Queue<XamlNode>();

System\Xaml\Parser\XamlScanner.cs (1)

47_readNodesQueue = new Queue<XamlScannerNode>();

System\Xaml\XamlNodeQueue.cs (1)

25_nodeQueue = new Queue<XamlNode>();

System\Xaml\XamlObjectReader.cs (1)

2494pendingNameScopes = new Queue<NameScopeMarkupInfo>();

Test.Utilities (1)

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

Text.Analyzers (2)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

VBCSCompiler.UnitTests (1)

TestableClientConnectionHost.cs (1)

18private readonly Queue<Func<Task<IClientConnection>>> _waitingTasks = new Queue<Func<Task<IClientConnection>>>();

534 references to Queue

Aspire.Cli.Tests (1)

Commands\PublishCommandPromptingIntegrationTests.cs (1)

896private readonly Queue<(string response, ResponseType type)> _responses = new();

Aspire.Hosting (1)

Pipelines\DistributedApplicationPipeline.cs (1)

266var queue = new Queue<string>(

ConfigurationSchemaGenerator (3)

ConfigSchemaEmitter.cs (2)

90var pathSegments = new Queue<string>(); 101private bool GeneratePathSegment(JsonObject currentNode, TypeSpec type, Queue<string> pathSegments)

RuntimeSource\Configuration.Binder\ConfigurationBindingGenerator.Parser.cs (1)

25private readonly Queue<TypeParseInfo> _typesToParse = new();

dotnet-svcutil-lib (12)

FrameworkFork\Microsoft.Xml\Xml\Serialization\CodeGenerator.cs (5)

41private Dictionary<Tuple<Type, string>, Queue<LocalBuilder>> _freeLocals; 85_freeLocals = new Dictionary<Tuple<Type, string>, Queue<LocalBuilder>>(); 237Queue<LocalBuilder> freeLocalQueue; 2706public void AddToFreeLocals(Dictionary<Tuple<Type, string>, Queue<LocalBuilder>> freeLocals) 2711Queue<LocalBuilder> freeLocalQueue;

FrameworkFork\System.Runtime.Serialization\System\Runtime\Serialization\ExtensionDataReader.cs (1)

45private Queue<IDataNode> _deserializedDataNodes;

FrameworkFork\System.ServiceModel\Internals\System\Runtime\InputQueue.cs (1)

25private Queue<IQueueReader> _readerQueue;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\QueuedObjectPool.cs (1)

31private Queue<T> _objectQueue;

FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\ServiceChannel.cs (1)

1995private Queue<IWaiter> _queue;

FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\ConcurrencyBehavior.cs (3)

228private Queue<ConcurrencyBehavior.IWaiter> _calloutMessageQueue; 229private Queue<ConcurrencyBehavior.IWaiter> _newMessageQueue; 240private ConcurrencyBehavior.IWaiter DequeueFrom(Queue<ConcurrencyBehavior.IWaiter> queue)

GenerateDocumentationAndConfigFiles (16)

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

31public static PooledObject<Queue<TItem>> GetPooledObject<TItem>(this ObjectPool<Queue<TItem>> pool) 32=> PooledObject<Queue<TItem>>.Create(pool); 109public static Queue<T> AllocateAndClear<T>(this ObjectPool<Queue<T>> pool) 111var set = pool.Allocate(); 265public static void ClearAndFree<T>(this ObjectPool<Queue<T>> pool, Queue<T> set)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

57public static PooledObject<Queue<TItem>> Create<TItem>(ObjectPool<Queue<TItem>> pool) 59return new PooledObject<Queue<TItem>>( 121private static Queue<TItem> Allocator<TItem>(ObjectPool<Queue<TItem>> pool) 124private static void Releaser<TItem>(ObjectPool<Queue<TItem>> pool, Queue<TItem> obj)

illink (11)

Linker.Dataflow\CompilerGeneratedCallGraph.cs (1)

48Queue<IMemberDefinition> queue = new();

Linker.Steps\MarkStep.cs (3)

63protected Queue<(MethodDefinition, DependencyInfo)> _methods; 65protected Queue<AttributeProviderPair> _assemblyLevelAttributes; 66protected Queue<(AttributeProviderPair, DependencyInfo, MessageOrigin)> _lateMarkedAttributes;

Linker\Driver.cs (5)

62if (!ProcessResponseFile(args, out var arguments)) 86readonly Queue<string> arguments; 105public Driver(Queue<string> arguments) 110public static bool ProcessResponseFile(string[] args, out Queue<string> result) 138public static void ParseResponseFile(TextReader reader, Queue<string> result)

Linker\InterfaceImplementor.cs (1)

45Queue<TypeDefinition> ifacesToCheck = new();

Linker\LinkContext.cs (1)

504var toProcess = new Queue<AssemblyDefinition>(assemblies);

Metrics (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Metrics.Legacy (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.AspNetCore.Components (2)

Rendering\RenderBatchBuilder.cs (2)

32public Queue<RenderQueueEntry> ComponentRenderQueue { get; } = new Queue<RenderQueueEntry>(); 33public Queue<int> ComponentDisposalQueue { get; } = new Queue<int>();

Microsoft.AspNetCore.Components.Endpoints (11)

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

6internal sealed class QueueBufferAdapter<TElement> : ICollectionBufferAdapter<Queue<TElement>, Queue<TElement>, TElement> 8public static Queue<TElement> CreateBuffer() => new(); 10public static Queue<TElement> Add(ref Queue<TElement> buffer, TElement element) 16public static Queue<TElement> ToResult(Queue<TElement> buffer) => buffer;

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

46var _ when type == (typeof(Queue<TElement>)) => true, 133var _ when type.IsAssignableTo(typeof(Queue<TElement>)) => 134new CollectionConverter<Queue<TElement>, QueueBufferAdapter<TElement>, Queue<TElement>, TElement>(elementTypeConverter),

Microsoft.AspNetCore.Components.Endpoints.Tests (3)

Binding\FormDataMapperTests.cs (3)

769var expected = new Queue<int>(new[] { 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 }); 770CanDeserialize_Collection<Queue<int>, Queue<int>, int>(expected);

Microsoft.AspNetCore.Components.WebAssembly (1)

Hosting\WebAssemblyCallQueue.cs (1)

21private static readonly Queue<Action> _pendingWork = new();

Microsoft.AspNetCore.Components.WebView (1)

Services\WebViewRenderer.cs (1)

13private readonly Queue<UnacknowledgedRenderBatch> _unacknowledgedRenderBatches = new();

Microsoft.AspNetCore.Http.Extensions (11)

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

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

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

Internal\Http2\Http2FrameWriter.cs (1)

104private readonly Queue<Http2OutputProducer> _waitingForMoreConnectionWindow = new();

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

Mocks\MockHttpContextFactory.cs (1)

13private readonly Queue<DefaultHttpContext> _cache = new Queue<DefaultHttpContext>();

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

251private readonly Queue<Message> _messageQueue;

Microsoft.Build.Tasks.CodeAnalysis (1)

src\Compilers\Core\MSBuildTask\Vbc.cs (1)

36private readonly Queue<VBError> _vbErrorLines = new Queue<VBError>();

Microsoft.Build.Tasks.CodeAnalysis.Sdk (1)

src\Compilers\Core\MSBuildTask\Vbc.cs (1)

36private readonly Queue<VBError> _vbErrorLines = new Queue<VBError>();

Microsoft.Cci.Extensions (2)

Extensions\CSharp\CSharpCciExtensions.cs (2)

139Queue<ITypeReference> typesToCheck = new Queue<ITypeReference>(); 175Queue<ITypeReference> typesToCheck = new Queue<ITypeReference>();

Microsoft.CodeAnalysis (36)

DiagnosticAnalyzer\AsyncQueue.cs (3)

28private readonly Queue<TElement> _data = new Queue<TElement>(); 29private Queue<TaskCompletionSource<Optional<TElement>>> _waiters; 174Queue<TaskCompletionSource<Optional<TElement>>> existingWaiters;

MetadataReader\MetadataDecoder.cs (10)

1976Queue<TypeDefinitionHandle> typeDefsToSearch = new Queue<TypeDefinitionHandle>(); 1977Queue<TypeSymbol> typeSymbolsToSearch = new Queue<TypeSymbol>(); 2035private void EnqueueTypeDefInterfacesAndBaseTypeOrThrow(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, TypeDefinitionHandle searchTypeDef) 2052private void EnqueueTypeToken(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, EntityHandle typeToken) 2073protected abstract void EnqueueTypeSymbolInterfacesAndBaseTypes(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, TypeSymbol typeSymbol); 2081protected abstract void EnqueueTypeSymbol(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, TypeSymbol typeSymbol);

PEWriter\MetadataWriter.cs (2)

497var typesToIndex = new Queue<ITypeDefinition>(); 514void createIndices(ITypeDefinition typeDef, Queue<ITypeDefinition> typesToIndex)

ReferenceManager\CommonReferenceManager.Binding.cs (3)

723private static readonly ObjectPool<Queue<AssemblyReferenceCandidate>> s_candidatesToExaminePool = new ObjectPool<Queue<AssemblyReferenceCandidate>>(() => new Queue<AssemblyReferenceCandidate>()); 729Queue<AssemblyReferenceCandidate> candidatesToExamine = s_candidatesToExaminePool.Allocate();

Syntax\SyntaxDiffer.cs (18)

Microsoft.CodeAnalysis.Analyzers (19)

MetaAnalyzers\DiagnosticAnalyzerAPIUsageAnalyzer.cs (2)

116var typesToProcess = new Queue<INamedTypeSymbol>(); 203var nodesToProcess = new Queue<(SyntaxNode node, bool inExecutableCode)>();

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.AnalyzerUtilities (18)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\RoslynAnalyzers\Utilities\FlowAnalysis\FlowAnalysis\Analysis\GlobalFlowStateAnalysis\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

152var currentNodes = new Queue<GlobalFlowStateAnalysisValueSet>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.BannedApiAnalyzers (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.CodeStyle (15)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.CSharp (4)

Symbols\Metadata\PE\MetadataDecoder.cs (4)

576protected override void EnqueueTypeSymbolInterfacesAndBaseTypes(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, TypeSymbol typeSymbol) 586protected override void EnqueueTypeSymbol(Queue<TypeDefinitionHandle> typeDefsToSearch, Queue<TypeSymbol> typeSymbolsToSearch, TypeSymbol typeSymbol)

Microsoft.CodeAnalysis.CSharp.CodeStyle (1)

src\Analyzers\CSharp\Analyzers\UseCollectionExpression\CSharpUseCollectionExpressionForFluentDiagnosticAnalyzer.cs (1)

49nameof(Queue<>),

Microsoft.CodeAnalysis.CSharp.Features (1)

src\Analyzers\CSharp\Analyzers\UseCollectionExpression\CSharpUseCollectionExpressionForFluentDiagnosticAnalyzer.cs (1)

49nameof(Queue<>),

Microsoft.CodeAnalysis.CSharp.Scripting.UnitTests (1)

ObjectFormatterTests.cs (1)

559var obj = new Queue<int>();

Microsoft.CodeAnalysis.CSharp.Symbol.UnitTests (1)

Symbols\CorLibrary\CorTypes.cs (1)

111Queue<NamespaceSymbol> namespaces = new Queue<NamespaceSymbol>();

Microsoft.CodeAnalysis.CSharp.Workspaces (2)

FindSymbols\CSharpDeclaredSymbolInfoFactoryService.cs (2)

171using var pooledQueue = SharedPools.Default<Queue<SyntaxNodeOrToken>>().GetPooledObject(); 172var queue = pooledQueue.Object;

Microsoft.CodeAnalysis.EditorFeatures (1)

IntelliSense\ViewTextSpan.cs (1)

109var sourceSpans = new Queue<SnapshotSpan>(start.MapToSourceSnapshots(span));

Microsoft.CodeAnalysis.ExpressionEvaluator.ResultProvider.Utilities (1)

Debugger\Engine\DkmWorkList.cs (1)

23private readonly Queue<Action> _workList;

Microsoft.CodeAnalysis.Features (1)

Shared\Utilities\ExtractTypeHelpers.cs (1)

142var unanalyzedTypeParameters = new Queue<ITypeParameterSymbol>(directlyReferencedTypeParameters);

Microsoft.CodeAnalysis.PerformanceSensitiveAnalyzers (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.PublicApiAnalyzers (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.ResxSourceGenerator (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.Test.Utilities (1)

CompilationVerifier.cs (1)

992var toVisit = new Queue<Compilation>(findDirectReferencedCompilations(original));

Microsoft.CodeAnalysis.UnitTests (1)

Collections\List\TestBase.Generic.cs (1)

136Queue<T> queue = new Queue<T>(count);

Microsoft.CodeAnalysis.VisualBasic (11)

Binding\Binder_Lookup.vb (7)

1022Dim lookIn As Queue(Of InterfaceInfo) = Nothing 1493lookIn As Queue(Of InterfaceInfo), 1649Dim lookIn As Queue(Of InterfaceInfo) = Nothing 1691ByRef allInterfaces As Queue(Of InterfaceInfo), 1869lookIn As Queue(Of InterfaceInfo), 2015lookIn As Queue(Of InterfaceInfo), 2063Dim lookIn As Queue(Of InterfaceInfo) = Nothing

Symbols\Metadata\PE\MetadataDecoder.vb (4)

489Protected Overrides Sub EnqueueTypeSymbolInterfacesAndBaseTypes(typeDefsToSearch As Queue(Of TypeDefinitionHandle), typeSymbolsToSearch As Queue(Of TypeSymbol), typeSymbol As TypeSymbol) 497Protected Overrides Sub EnqueueTypeSymbol(typeDefsToSearch As Queue(Of TypeDefinitionHandle), typeSymbolsToSearch As Queue(Of TypeSymbol), typeSymbol As TypeSymbol)

Microsoft.CodeAnalysis.Workspaces (18)

Differencing\EditScript.cs (1)

50var queue = new Queue<IEnumerable<TNode>>();

Shared\Extensions\INamespaceSymbolExtensions.cs (2)

131using var namespaceQueue = SharedPools.Default<Queue<INamespaceOrTypeSymbol>>().GetPooledObject(); 159Queue<INamespaceOrTypeSymbol> namespaceQueue)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (15)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Microsoft.DotNet.Build.Tasks.Packaging (1)

CreateTrimDependencyGroups.cs (1)

85var newDependencyGroups = new Queue<TaskItemPackageDependencyGroup>();

Microsoft.Extensions.AI (1)

ChatReduction\MessageCountingChatReducer.cs (1)

48Queue<ChatMessage> reducedMessages = new(capacity: _targetCount);

Microsoft.Extensions.AI.Abstractions.Tests (2)

test\Shared\JsonSchemaExporter\TestTypes.cs (2)

817yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1300[JsonSerializable(typeof(Queue<double>))]

Microsoft.Extensions.Http.Diagnostics (1)

Http\DownstreamDependencyMetadataManager.cs (1)

195Queue<RequestMetadataTrieNode> queue = new();

Microsoft.Extensions.Http.Resilience.Tests (1)

Hedging\HedgingTests.cs (1)

37private readonly Queue<HttpResponseMessage> _responses = new();

Microsoft.Extensions.Logging.Console (1)

ConsoleLoggerProcessor.cs (1)

17private readonly Queue<LogMessageEntry> _messageQueue;

Microsoft.Maui.Controls (8)

BindableObject.cs (3)

581 Queue<SetValueArgs> delayQueue = context.DelayedSetters; 593 Queue<SetValueArgs> delayQueue = context.DelayedSetters; 849 public Queue<SetValueArgs> DelayedSetters;

Element\Element.cs (2)

700 var queue = new Queue<Element>(16); 806 var queue = new Queue<Element>(16);

LockingSemaphore.cs (1)

12 readonly Queue<TaskCompletionSource<bool>> _waiters = new Queue<TaskCompletionSource<bool>>();

StyleSheets\CssReader.cs (1)

20 readonly Queue<char> _cache = new Queue<char>();

TemplateUtilities.cs (1)

87 var queue = new Queue<Element>(16);

Microsoft.Maui.Essentials (1)

Compass\LowPassFilter.shared.cs (1)

10 readonly Queue<float> history = new Queue<float>(length);

Microsoft.ML.AutoML (2)

Tuner\SmacTuner.cs (2)

28private Queue<Parameter> _candidates; 115internal Queue<Parameter> Candidates => _candidates;

Microsoft.ML.Core (2)

Data\Repository.cs (1)

289private Queue<KeyValuePair<string, Stream>> _closed;

Utilities\ThreadUtils.cs (1)

35private static readonly Queue<(Delegate, object, TaskCompletionSource<bool>)> _queue = new Queue<(Delegate, object, TaskCompletionSource<bool>)>();

Microsoft.ML.Core.Tests (1)

UnitTests\TestHosts.cs (1)

56Queue<IHost> queue = new Queue<IHost>();

Microsoft.ML.FastTree (2)

Training\EarlyStoppingCriteria.cs (2)

204private protected Queue<float> PastScores; 232private float GetRecentAvg(Queue<float> recentScores)

Microsoft.ML.StandardTrainers (1)

Optimizer\OptimizationMonitor.cs (1)

198private readonly Queue<float> _pastValues;

Microsoft.ML.Sweeper (1)

Algorithms\NelderMead.cs (1)

76private readonly Queue<KeyValuePair<ParameterSet, float[]>> _pendingSweepsNotSubmitted;

Microsoft.ML.Transforms (1)

Expression\Lexer.cs (1)

52private readonly Queue<Token> _queue; // For multiple returns.

Microsoft.VisualStudio.LanguageServices (4)

CommonControls\MemberSelectionViewModel.cs (1)

168var queue = new Queue<ISymbol>();

MoveStaticMembers\StaticMemberSelectionViewModel.cs (1)

85var queue = new Queue<ISymbol>();

PullMemberUp\MainDialog\BaseTypeTreeNodeViewModel.cs (1)

50var queue = new Queue<BaseTypeTreeNodeViewModel>();

Utilities\AutomationDelegatingListView.cs (1)

49var peersToProcess = new Queue<AutomationPeer>(base.GetChildrenCore() ?? SpecializedCollections.EmptyEnumerable<AutomationPeer>());

Microsoft.VisualStudio.LanguageServices.Implementation (7)

CodeModel\AbstractCodeModelService.AbstractCodeModelEventCollector.cs (2)

34public Queue<CodeModelEvent> Collect(SyntaxTree oldTree, SyntaxTree newTree) 36var queue = new Queue<CodeModelEvent>();

CodeModel\AbstractCodeModelService.cs (1)

1250public Queue<CodeModelEvent> CollectCodeModelEvents(SyntaxTree oldTree, SyntaxTree newTree)

CodeModel\CodeModelEventQueue.cs (2)

14private readonly Queue<CodeModelEvent> _eventQueue; 16public CodeModelEventQueue(Queue<CodeModelEvent> eventQueue)

CodeModel\FileCodeModel_Events.cs (1)

52var eventQueue = this.CodeModelService.CollectCodeModelEvents(oldTree, newTree);

CodeModel\ICodeModelService.cs (1)

349Queue<CodeModelEvent> CollectCodeModelEvents(SyntaxTree oldTree, SyntaxTree newTree);

mscorlib (1)

mscorlib.cs (1)

57[assembly:System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Generic.Queue<>))]

netstandard (1)

netstandard.cs (1)

129[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Generic.Queue<>))]

PresentationCore (4)

System\Windows\Input\Stylus\Common\DynamicRenderer.cs (1)

1207private Queue<StrokeInfo> _renderCompleteDRThreadStrokeInfoList = new Queue<StrokeInfo>();

System\Windows\Input\Stylus\Wisp\WispLogic.cs (1)

3676private Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();

System\Windows\Media\Animation\TimeManager.cs (1)

899private Queue<WeakReference> _eventQueue;

System\Windows\Media\ChannelManager.cs (1)

231private Queue<DUCE.Channel> _freeSyncChannels;

PresentationFramework (2)

MS\Internal\Data\DataBindEngine.cs (1)

709private Queue<DataBindOperation> _crossThreadQueue = new Queue<DataBindOperation>();

System\Windows\Controls\ItemContainerGenerator.cs (1)

2797private Queue<DependencyObject> _recyclableContainers = new Queue<DependencyObject>();

Roslyn.Diagnostics.Analyzers (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

RunTests (1)

ProcessUtil.cs (1)

72var toVisit = new Queue<Process>();

Shared.Tests (4)

JsonSchemaExporter\TestTypes.cs (2)

817yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1300[JsonSerializable(typeof(Queue<double>))]

Throw\ThrowTest.cs (2)

331exception = Assert.Throws<ArgumentNullException>(() => Throw.IfNullOrEmpty((Queue<int>?)null, "foo")); 351var queue = new Queue<int>();

System (1)

src\libraries\shims\System\ref\System.cs (1)

137[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Generic.Queue<>))]

System.CodeDom (1)

src\libraries\Common\src\System\CodeDom\CodeTypeReference.cs (1)

141var q = new Queue<int>();

System.Collections (3)

artifacts\obj\System.Collections\Debug\net10.0\System.Collections.Forwards.cs (1)

10[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Generic.Queue<>))]

System\Collections\Generic\SortedSet.cs (1)

237var processQueue = new Queue<Node>();

System\Collections\Generic\SortedSet.TreeSubSet.cs (1)

253Queue<Node> processQueue = new Queue<Node>();

System.ComponentModel.Composition (5)

System\ComponentModel\Composition\ContractNameServices.cs (5)

120Queue<Type> genericTypeArguments = new Queue<Type>(type.GetGenericArguments()); 211private static void WriteGenericType(StringBuilder typeName, Type type, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 233private static void WriteGenericTypeName(StringBuilder typeName, Type type, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 248private static void WriteTypeArgumentsString(StringBuilder typeName, int argumentsCount, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 295Queue<Type> typeArguments = new Queue<Type>(types);

System.Composition.Hosting (1)

System\Composition\Hosting\Core\UpdateResult.cs (1)

16private readonly Queue<ExportDescriptorProvider> _remainingProviders;

System.Diagnostics.Process (2)

System\Diagnostics\AsyncStreamReader.cs (1)

37private readonly Queue<string?> _messageQueue;

System\Diagnostics\Process.NonUap.cs (1)

44var descendantProcesses = new Queue<Process>();

System.IO.Ports (4)

System\IO\Ports\SerialStream.Unix.cs (4)

38private readonly Queue<SerialStreamIORequest> _readQueue = new(); 40private readonly Queue<SerialStreamIORequest> _writeQueue = new(); 847private static int DoIORequest(Queue<SerialStreamIORequest> q, object queueLock, RequestProcessor op) 1016private static void RemoveCompletedTasks(Queue<SerialStreamIORequest> queue, object queueLock)

System.Linq (2)

System\Linq\ElementAt.cs (1)

160Queue<TSource> queue = new();

System\Linq\Take.cs (1)

107Queue<TSource> queue;

System.Linq.AsyncEnumerable (2)

System\Linq\ElementAtAsync.cs (1)

147Queue<TSource> queue = new();

System\Linq\Take.cs (1)

135Queue<TSource> queue;

System.Linq.Expressions (1)

System\Linq\Expressions\DebugViewWriter.cs (1)

37private Queue<LambdaExpression>? _lambdas;

System.Linq.Parallel (10)

System\Linq\Parallel\Channels\SynchronousChannel.cs (1)

27private Queue<T>? _queue;

System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (6)

59private readonly Queue<Pair<TKey, TOutput>>[] _buffers; 132_buffers = new Queue<Pair<TKey, TOutput>>[partitionCount]; 239private readonly Queue<Pair<TKey, TOutput>>?[] _privateBuffer; 256_privateBuffer = new Queue<Pair<TKey, TOutput>>[partitionCount]; 392Queue<Pair<TKey, TOutput>> buffer = _mergeHelper._buffers[producer]; 462var privateChunk = _privateBuffer[producer];

System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (3)

33private readonly Queue<Pair<TKey, TOutput>>[] _buffers; // The buffer for the results 62Queue<Pair<TKey, TOutput>>[] buffers, 150Queue<Pair<TKey, TOutput>>[] buffers, object[] bufferLocks,

System.Net.Sockets (1)

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

84private static readonly Queue<int> s_registeredContextsFreeList = [];

System.Private.CoreLib (9)

src\libraries\System.Private.CoreLib\src\System\Collections\Generic\Queue.cs (4)

363/// Sets the capacity of a <see cref="Queue{T}"/> object to the specified number of entries. 424private readonly Queue<T> _queue; 429internal Enumerator(Queue<T> queue) 450Queue<T> q = _queue;

src\libraries\System.Private.CoreLib\src\System\Collections\Generic\QueueDebugView.cs (2)

10private readonly Queue<T> _queue; 12public QueueDebugView(Queue<T> queue)

src\libraries\System.Private.CoreLib\src\System\IO\Enumeration\FileSystemEnumerator.Unix.cs (1)

25private Queue<(string Path, int RemainingDepth)>? _pending;

src\libraries\System.Private.CoreLib\src\System\SearchValues\Strings\Helpers\AhoCorasickBuilder.cs (1)

138var queue = new Queue<(char Char, int Index)>();

src\libraries\System.Private.CoreLib\src\System\SearchValues\Strings\Helpers\AhoCorasickNode.cs (1)

81public readonly void AddChildrenToQueue(Queue<(char Char, int Index)> queue)

System.Private.DataContractSerialization (3)

src\libraries\Common\src\System\CodeDom\CodeTypeReference.cs (1)

141var q = new Queue<int>();

System\Runtime\Serialization\DataContract.cs (1)

1160Queue<Type> itemTypeQueue = new Queue<Type>();

System\Runtime\Serialization\ExtensionDataReader.cs (1)

46private Queue<IDataNode>? _deserializedDataNodes;

System.Private.Windows.Core (2)

System\Private\Windows\BinaryFormat\Deserializer\Deserializer.cs (2)

74private Queue<PendingSerializationInfo>? _pendingSerializationInfo; 90private readonly Queue<SerializationRecordId> _pendingCompletions = [];

System.Private.Xml (6)

System\Xml\Schema\ContentValidator.cs (1)

1451var unmarked = new Queue<BitSet>();

System\Xml\Serialization\CodeGenerator.cs (5)

40private Dictionary<(Type, string), Queue<LocalBuilder>>? _freeLocals; 93_freeLocals = new Dictionary<(Type, string), Queue<LocalBuilder>>(); 223Queue<LocalBuilder>? freeLocalQueue; 1608public void AddToFreeLocals(Dictionary<(Type, string), Queue<LocalBuilder>> freeLocals) 1613Queue<LocalBuilder>? freeLocalQueue;

System.Resources.Extensions (2)

System\Resources\Extensions\BinaryFormat\Deserializer\Deserializer.cs (2)

77private Queue<PendingSerializationInfo>? _pendingSerializationInfo; 93private readonly Queue<SerializationRecordId> _pendingCompletions = [];

System.ServiceModel.Primitives (19)

Internals\System\Runtime\InputQueue.cs (1)

22private Queue<IQueueReader> _readerQueue;

System\ServiceModel\Channels\CommunicationObject.cs (1)

1077private Queue<Exception> _exceptions = new Queue<Exception>();

System\ServiceModel\Channels\QueuedObjectPool.cs (1)

31private Queue<T> _objectQueue;

System\ServiceModel\Channels\ReliableChannelBinder.cs (10)

896private Queue<IWaiter> _getChannelQueue; 900private Queue<IWaiter> _waitQueue; 1079private Queue<IWaiter> GetQueue(bool canGetChannel) 1164Queue<IWaiter> temp1 = null; 1165Queue<IWaiter> temp2 = null; 1273Queue<IWaiter> waiters = waiter.CanGetChannel ? _getChannelQueue : _waitQueue; 1438private void SetWaiters(Queue<IWaiter> waiters, TChannel channel) 1620Queue<IWaiter> temp1; 1621Queue<IWaiter> temp2; 1637private void UnblockWaiters(Queue<IWaiter> waiters, bool close)

System\ServiceModel\Channels\ServiceChannel.cs (1)

2032private Queue<IWaiter> _queue;

System\ServiceModel\Channels\TransmissionStrategy.cs (2)

63private readonly Queue<IQueueAdder> _waitQueue = new Queue<IQueueAdder>(); 252Queue<IQueueAdder> adders = null;

System\ServiceModel\Dispatcher\ConcurrencyBehavior.cs (3)

227private Queue<ConcurrencyBehavior.IWaiter> _calloutMessageQueue; 228private Queue<ConcurrencyBehavior.IWaiter> _newMessageQueue; 239private ConcurrencyBehavior.IWaiter DequeueFrom(Queue<ConcurrencyBehavior.IWaiter> queue)

System.Text.Json (8)

src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)

116var childlessQueue = new Queue<int>(); // the queue of nodes without children or whose children have been visited

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

124else if ((actualTypeToConvert = typeToConvert.GetCompatibleGenericBaseClass(typeof(Queue<>))) != null)

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

10where TCollection : Queue<TElement>

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

251/// Creates serialization metadata for types assignable to <see cref="Queue{T}"/>. 262where TCollection : Queue<TElement> 287/// Creates serialization metadata for types assignable to <see cref="Queue{T}"/>.

System\Text\Json\ValueQueue.cs (2)

12/// A struct variant of <see cref="Queue{T}"/> that only allocates for Counts > 1. 19private Queue<T>? _multiple;

System.Text.Json.SourceGeneration (3)

Helpers\KnownTypeSymbols.cs (1)

58public INamedTypeSymbol? QueueOfTType => GetOrResolveType(typeof(Queue<>), ref _QueueOfTType);

JsonSourceGenerator.Parser.cs (1)

45private readonly Queue<TypeToGenerate> _typesToGenerate = new();

src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)

116var childlessQueue = new Queue<int>(); // the queue of nodes without children or whose children have been visited

System.Text.RegularExpressions (4)

System\Text\RegularExpressions\Symbolic\SymbolicRegexMatcher.Explore.cs (4)

22Queue<MatchingState<TSet>> toExplore = new(); 71static (int nfaId, (SymbolicRegexMatcher<TSet> Matcher, HashSet<MatchingState<TSet>> Seen, Queue<MatchingState<TSet>> ToExplore) args) => 98static void EnqueueAll(MatchingState<TSet>[] states, HashSet<MatchingState<TSet>> seen, Queue<MatchingState<TSet>> toExplore) 106static void EnqueueIfUnseen(MatchingState<TSet> state, HashSet<MatchingState<TSet>> seen, Queue<MatchingState<TSet>> queue)

System.Threading.Tasks.Dataflow (3)

Blocks\BatchBlock.cs (1)

241private readonly Queue<T> _messages = new Queue<T>();

Blocks\BroadcastBlock.cs (1)

496private readonly Queue<TOutput> _messages = new Queue<TOutput>();

Blocks\JoinBlock.cs (1)

481private readonly Queue<T>? _messages;

System.Windows.Forms (3)

System\Windows\Forms\Control.cs (1)

273private Queue<ThreadMethodEntry>? _threadCallbackList;

System\Windows\Forms\Dialogs\TaskDialog\TaskDialog.cs (1)

78private readonly Queue<TaskDialogPage> _waitingNavigationPages = new();

System\Windows\Forms\SendKeys\SendKeys.cs (1)

86private static readonly Queue<SKEvent> s_events = new();

System.Windows.Input.Manipulations (3)

System\Windows\Input\Manipulations\ManipulationSequence.cs (3)

1051private static float GetVelocity(Queue<ManipulationState> queue, PropertyAccessor accessor) 1068private static float CalculateWeightedMovingAverage(Queue<ManipulationState> queue, PropertyAccessor accessor) 1130private static float CalculateMovingAverage(Queue<ManipulationState> queue, PropertyAccessor accessor, float defaultValue)

System.Xaml (6)

System\Xaml\Context\NameFixupGraph.cs (1)

27private Queue<NameFixupToken> _resolvedTokensPendingProcessing;

System\Xaml\Parser\NodeStreamSorter.cs (1)

19private Queue<XamlNode> _buffer;

System\Xaml\Parser\XamlScanner.cs (1)

34private Queue<XamlScannerNode> _readNodesQueue;

System\Xaml\XamlNodeQueue.cs (1)

15private Queue<XamlNode> _nodeQueue;

System\Xaml\XamlObjectReader.cs (2)

2483private Queue<NameScopeMarkupInfo> pendingNameScopes; 2531public Queue<NameScopeMarkupInfo> PendingNameScopes

Test.Utilities (16)

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

Text.Analyzers (17)

src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

201var nodesToProcess = new Queue<SyntaxNode>();

src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

92var operationsToProcess = new Queue<IOperation>();

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\Extensions.cs (8)

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\ObjectPools\PooledObject.cs (7)

VBCSCompiler.UnitTests (1)

TestableClientConnectionHost.cs (1)

18private readonly Queue<Func<Task<IClientConnection>>> _waitingTasks = new Queue<Func<Task<IClientConnection>>>();