Queue

3 types derived from Queue

System.Private.CoreLib (1)

src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)

7084private sealed class WhenEachState : Queue<Task>, IValueTaskSource, ITaskCompletionAction

System.Windows.Input.Manipulations (2)

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

1228private class HistoryQueue : Queue<ManipulationState> 1322private class SmoothingQueue : Queue<ManipulationState>

241 instantiations of Queue

aspire (6)

Commands\AppHostLauncher.cs (3)

986var lines = new Queue<string>(maxLines); 987var guestCommandLines = new Queue<string>(maxLines); 1052var entries = new Queue<CliLogFormat.FileLogEntry>(maxLines);

Interaction\ConsoleLogBufferContext.cs (1)

20private readonly Queue<(TextWriter Writer, string Message)> _bufferedMessages = new();

Packaging\PackageChannel.cs (1)

716var packagesToProcess = new Queue<string>(resolvedPackageIds);

Projects\PrebuiltAppHostServer.cs (1)

372var pending = new Queue<string>();

Aspire.Cli.Tests (8)

Commands\NewCommandTests.cs (1)

3007var selectedParents = new Queue<string?>([collidingParent.FullName, validParent.FullName]);

Commands\PublishCommandPromptingIntegrationTests.cs (1)

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

Interaction\ExtensionInteractionServiceTests.cs (2)

114var selections = new Queue<string?>([invalidPath, validPath]); 155var selections = new Queue<string?>([invalidPath, null]);

Mcp\ApiDocs\ApiDocsIndexServiceTests.cs (1)

610private readonly Queue<string?> _sitemapContents = new(sitemapContents);

Mcp\Docs\DocsIndexServiceTests.cs (1)

1396private readonly Queue<string?> _contents = new(contents);

ProfileCaptureOptionsTests.cs (1)

212var queue = new Queue<int>(ports.Length == 0 ? [5000, 5001, 5002] : ports);

TestServices\TestInteractionService.cs (1)

16private readonly Queue<(string Response, ResponseType Type)> _responses = new();

Aspire.Dashboard.Tests (2)

Model\DashboardClientTests.cs (1)

731_items = new Queue<T>(items ?? []);

tests\Shared\Telemetry\InMemoryTelemetryRepository.cs (1)

753? new Queue<OtlpTrace>(latestItemCount)

Aspire.Hosting (5)

ApplicationModel\CommandsConfigurationExtensions.cs (1)

470private readonly Queue<string> _lines = new();

ApplicationModel\ResourceExtensions.cs (1)

1555var toProcess = new Queue<IResource>();

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1619Queue<ResourceLogLine>? tailBuffer = serverTailLineCount > 0 ? new Queue<ResourceLogLine>(serverTailLineCount) : null;

Backchannel\BackchannelLoggerProvider.cs (1)

11private readonly Queue<BackchannelLogEntry> _replayBuffer = new();

Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure (3)

AzureProvisioningController.cs (1)

1248var queue = new Queue<(IResource Resource, IAzureResource AzureResource)>();

Provisioning\Internal\DefaultArmClientProvider.cs (1)

369var pendingDeployments = new Queue<ResourceIdentifier>();

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure.Kubernetes (1)

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure.Tests (2)

ProvisioningTestHelpers.cs (2)

220public Queue<object?> DeploymentProbeResults { get; } = new(); 221public Queue<AzureDeploymentState?> DeploymentStates { get; } = new();

Aspire.Hosting.Docker (1)

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Dotnet (1)

DotnetProjectResource.cs (1)

162var pendingSteps = new Queue<PipelineStep>();

ConfigurationSchemaGenerator (2)

ConfigSchemaEmitter.cs (1)

90var pathSegments = new Queue<string>();

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

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

dotnet-svcutil-lib (6)

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

2720freeLocalQueue = new Queue<LocalBuilder>();

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

33_readerQueue = new Queue<IQueueReader>();

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

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

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

2003_queue = new Queue<IWaiter>();

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

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

GenerateDocumentationAndConfigFiles (1)

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

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

ILCompiler.Compiler (2)

Compiler\Dataflow\CompilerGeneratedCallGraph.cs (1)

56Queue<TypeSystemEntity> queue = new();

Compiler\DependencyAnalysis\ModuleInitializerListNode.cs (1)

66var modulesToExpand = new Queue<ModuleGraphNode>(allModules);

ILCompiler.MetadataTransform (1)

Internal\Metadata\NativeFormat\Writer\NativeMetadataWriter.cs (1)

274protected Queue<MetadataRecord> _queue = new Queue<MetadataRecord>();

illink (8)

Linker.Dataflow\CompilerGeneratedCallGraph.cs (1)

48Queue<IMemberDefinition> queue = new();

Linker.Steps\MarkStep.cs (3)

225_methods = new Queue<(MethodDefinition, DependencyInfo)>(); 227_assemblyLevelAttributes = new Queue<AttributeProviderPair>(); 228_lateMarkedAttributes = new Queue<(AttributeProviderPair, DependencyInfo, MessageOrigin)>();

Linker\Driver.cs (1)

123result = new Queue<string>();

Linker\InterfaceImplementor.cs (1)

45Queue<TypeDefinition> ifacesToCheck = new();

Linker\LinkContext.cs (1)

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

Linker\TypeMapHandler.cs (1)

319Queue<AssemblyDefinition> toVisit = new();

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

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

8public static Queue<TElement> CreateBuffer() => new();

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)

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

Microsoft.AspNetCore.Http.Extensions (1)

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

8public static Queue<TElement> CreateBuffer() => new();

Microsoft.AspNetCore.Razor.Utilities.Shared (1)

src\roslyn\src\Razor\src\Shared\Microsoft.AspNetCore.Razor.SharedUtilities\PooledObjects\QueuePool`1.Policy.cs (1)

31public override Queue<T> Create() => new();

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

Internal\Http2\Http2FrameWriter.cs (1)

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

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

256_messageQueue = new Queue<Message>();

Microsoft.Build (7)

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

167_unsubmittedRequests = new Queue<PendingUnsubmittedBuildRequests>();

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

795var targetsToCheckForAfterTargets = new Queue<string>();

BackEnd\Components\Scheduler\Scheduler.cs (2)

601_pendingRequestCoresCallbacks = new Queue<TaskCompletionSource<int>>(); 2802Queue<SchedulableRequest> blockingRequests = new Queue<SchedulableRequest>();

BuildCheck\Checks\NoEnvironmentVariablePropertyCheck.cs (1)

24private readonly Queue<(string projectPath, BuildCheckDataContext<EnvironmentVariableCheckData>)> _buildCheckResults = new Queue<(string, BuildCheckDataContext<EnvironmentVariableCheckData>)>();

Graph\ProjectGraph.cs (2)

593var partialRoots = new Queue<ProjectGraphNode>(graphNodes.Count); 646var edgesToVisit = new Queue<ProjectGraphBuildRequest>();

Microsoft.Build.Tasks.CodeAnalysis (1)

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

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

Microsoft.CodeAnalysis (8)

DiagnosticAnalyzer\AsyncQueue.cs (2)

28private readonly Queue<TElement> _data = new Queue<TElement>(); 278_waiters ??= new Queue<TaskCompletionSource<Optional<TElement>>>();

MetadataReader\MetadataDecoder.cs (2)

1976Queue<TypeDefinitionHandle> typeDefsToSearch = new Queue<TypeDefinitionHandle>(); 1977Queue<TypeSymbol> typeSymbolsToSearch = new Queue<TypeSymbol>();

PEWriter\MetadataWriter.cs (1)

497var typesToIndex = new Queue<ITypeDefinition>();

ReferenceManager\CommonReferenceManager.Binding.cs (1)

723private static readonly ObjectPool<Queue<AssemblyReferenceCandidate>> s_candidatesToExaminePool = new ObjectPool<Queue<AssemblyReferenceCandidate>>(() => new Queue<AssemblyReferenceCandidate>());

Syntax\SyntaxDiffer.cs (2)

619var queue = new Queue<SyntaxNodeOrToken>(); 702var queue = new Queue<SyntaxNodeOrToken>(n);

Microsoft.CodeAnalysis.Analyzers (4)

MetaAnalyzers\DiagnosticAnalyzerAPIUsageAnalyzer.cs (2)

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

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

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

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

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

Microsoft.CodeAnalysis.AnalyzerUtilities (3)

src\97c55a67c449f67c\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

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

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

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

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

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

Microsoft.CodeAnalysis.CSharp.Workspaces (1)

SyncedSource\FileBasedPrograms\VirtualProjectBuilder.cs (1)

340var filesToProcess = new Queue<string>();

Microsoft.CodeAnalysis.Features (1)

Shared\Utilities\ExtractTypeHelpers.cs (1)

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

Microsoft.CodeAnalysis.NetAnalyzers (4)

Microsoft.CodeQuality.Analyzers\QualityGuidelines\AvoidMultipleEnumerations\AvoidMultipleEnumerations.DataFlowOperationVisitor.cs (1)

169var queue = new Queue<IOperation>();

src\8ce1f4f68b646e6d\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

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

src\sdk\src\Microsoft.CodeAnalysis.NetAnalyzers\src\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

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

src\sdk\src\Microsoft.CodeAnalysis.NetAnalyzers\src\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

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

Microsoft.CodeAnalysis.ResxSourceGenerator (2)

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

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

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

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

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

Differencing\EditScript.cs (1)

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

Log\WorkspaceStructureLogger.cs (1)

273var namespaces = new Queue<INamespaceSymbol>();

Microsoft.DotNet.ApiCompatibility (1)

Mapping\AssemblyMapper.cs (1)

51Queue<INamespaceSymbol> queue = new();

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

CreateTrimDependencyGroups.cs (1)

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

Microsoft.DotNet.HotReload.Watch (1)

Build\ProjectGraphUtilities.cs (1)

125var queue = new Queue<ProjectGraphNode>();

Microsoft.DotNet.PackageValidation (2)

Package.cs (1)

228Queue<NuGetFramework> tfmQueue = new(AssemblyReferences.Keys);

Validators\CompatibleFrameworkInPackageValidator.cs (1)

39Queue<(NuGetFramework, IReadOnlyList<ContentItem>)> compileAssetsQueue = new();

Microsoft.DotNet.ProjectTools (1)

src\sdk\src\Cli\Microsoft.DotNet.FileBasedPrograms\VirtualProjectBuilder.cs (1)

346var filesToProcess = new Queue<string>();

Microsoft.Extensions.AI (1)

ChatReduction\MessageCountingChatReducer.cs (1)

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

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

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.QueueDouble.g.cs (1)

33ObjectCreator = () => new global::System.Collections.Generic.Queue<double>(),

parent\parent\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.AI.Tests (6)

ChatCompletion\FunctionInvokingChatClientApprovalsTests.cs (6)

1031Func<Queue<List<ChatMessage>>> expectedDownstreamClientInput = () => new Queue<List<ChatMessage>>( 1045Func<Queue<List<ChatMessage>>> downstreamClientOutput = () => new Queue<List<ChatMessage>>( 1942new Queue<List<ChatMessage>>(new[] { downstreamClientOutput }), 1944expectedDownstreamClientInput is null ? null : new Queue<List<ChatMessage>>(new[] { expectedDownstreamClientInput }), 2030new Queue<List<ChatMessage>>(new[] { downstreamClientOutput }), 2032expectedDownstreamClientInput is null ? null : new Queue<List<ChatMessage>>(new[] { expectedDownstreamClientInput }),

Microsoft.Extensions.Configuration.Binder.SourceGeneration (1)

ConfigurationBindingGenerator.Parser.cs (1)

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

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

Logging\FakeLogCollectorTests.LogEnumeration.cs (5)

36new Queue<string>(["Log A", "Log B", "Sync"]), // Wait for event A and B followed by Sync 52new Queue<string>(["Log C", "Sync"]), // Wait for another Log C followed by Sync 77var containsSequence = ContainsNonContinuousSequence(snapshot, new Queue<string>(["Log A", "Log B", "Sync", "Log C", "Sync"])); 94new Queue<string>(["A", "B"]), 103new Queue<string>(["A", "B", "C"]),

Microsoft.Extensions.Http.Diagnostics (1)

Http\HttpDependencyMetadataResolver.cs (1)

200Queue<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)

311_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.TemplateEngine.Cli (1)

Commands\Example.cs (1)

58Queue<Command> probes = new();

Microsoft.TemplateEngine.Utils (2)

DirectedGraph.cs (2)

52Queue<T> noDependenciesQueue = new(inDegreeLookup.Where(kp => kp.Value == 0).Select(kp => kp.Key)); 98Queue<T> directDependents = new(vertices);

Microsoft.TestPlatform.CoreUtilities (1)

Utilities\JobQueue.cs (1)

124_jobsQueue = new Queue<Job<T>>();

Microsoft.TestPlatform.CrossPlatEngine (1)

Client\Parallel\ParallelOperationManager.cs (1)

61private readonly Queue<ProviderSpecificWorkload<TWorkload>> _pendingWorkloads = new();

Microsoft.Win32.SystemEvents (1)

Microsoft\Win32\SystemEvents.cs (1)

770s_threadCallbackList = new Queue<Delegate>();

MSBuild (1)

OutOfProcTaskHostNode.cs (1)

262_receivedPackets = new Queue<INodePacket>();

MSBuild.Coordinator (2)

CoordinatorServer.cs (1)

453Queue<BuildGrant> pendingNotifications = new(newlyGranted.Length);

NodeBudgetManager.cs (1)

17private readonly Queue<BuildGrant> _waitQueue = new();

NuGet.CommandLine.XPlat (1)

Utility\TableParser.cs (1)

54var queue = new Queue<FormattedCell>();

NuGet.Commands (8)

RestoreCommand\DependencyGraphResolver.cs (3)

340Queue<(LibraryDependencyIndex, LibraryRangeIndex, GraphNode<RemoteResolveResult>)> itemsToFlatten = new(); 930Queue<DependencyGraphItem> dependencyGraphItemQueue = new(DependencyGraphItemQueueSize); 1152Queue<DependencyGraphItem> newDependencyGraphItemQueue = new(DependencyGraphItemQueueSize);

RestoreCommand\LockFileBuilder.cs (1)

534Queue<GraphNode<RemoteResolveResult>> queue = new Queue<GraphNode<RemoteResolveResult>>();

RestoreCommand\Logging\TransitiveNoWarnUtils.cs (1)

92var queue = new Queue<DependencyNode>();

RestoreCommand\RestoreRunner.cs (2)

69var requests = new Queue<RestoreSummaryRequest>(restoreRequests); 135var requests = new Queue<RestoreSummaryRequest>(restoreRequests);

RestoreCommand\Utility\IncludeFlagUtils.cs (1)

81var nodeQueue = new Queue<DependencyNode>(1);

NuGet.DependencyResolver.Core (2)

GraphModel\GraphOperations.cs (2)

701return new Queue<NodeWithState<TItem, TState>>(); 733return new Queue<GraphNode<TItem>>();

NuGet.PackageManagement (7)

NuGetPackageManager.cs (1)

2060var results = new Queue<KeyValuePair<SourceRepository, Task<bool>>>();

PackageDownloader.cs (1)

84var groups = new Queue<List<SourceRepository>>();

PackagePreFetcher.cs (1)

60var toDownload = new Queue<NuGetProjectAction>();

Resolution\PrunePackageTree.cs (1)

79var queue = new Queue<SourcePackageDependencyInfo>();

Resolution\ResolverGather.cs (1)

28private readonly Queue<GatherRequest> _gatherRequests = new Queue<GatherRequest>();

Resolution\UninstallResolver.cs (1)

105var breathFirstSearchQueue = new Queue<PackageIdentity>();

Utility\XElementExtensions.cs (1)

130var pendingComments = new Queue<XComment>();

NuGet.ProjectModel (1)

ProjectLockFile\PackagesLockFileUtilities.cs (1)

185var queue = new Queue<Tuple<string, string>>();

NuGet.Resolver (2)

ResolverUtility.cs (2)

215var queue = new Queue<ResolverPackage>(); 419var queue = new Queue<QueueNode>();

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)

706private 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\roslyn\src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

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

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

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

SelectTests (1)

GraphAffectedProjects.cs (1)

408var queue = new Queue<string>();

Shared.Tests (3)

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.QueueDouble.g.cs (1)

33ObjectCreator = () => new global::System.Collections.Generic.Queue<double>(),

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)

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

System.CodeDom (1)

src\runtime\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.CommandLine (1)

EnumerableExtensions.cs (1)

18var queue = new Queue<T>();

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.DirectoryServices.AccountManagement (6)

System\DirectoryServices\AccountManagement\AD\ADDNLinkedAttrSet.cs (6)

1034bookmark.membersQueue = new Queue<IEnumerable>(_membersQueue.Count); 1099bookmark.memberSearcherQueue = new Queue<DirectorySearcher>(_memberSearchersQueue.Count); 1287private readonly Queue<IEnumerable> _membersQueue = new Queue<IEnumerable>(); 1289private readonly Queue<IEnumerable> _originalMembers = new Queue<IEnumerable>(); // the membership we started off with (before recursing) 1321private readonly Queue<DirectorySearcher> _memberSearchersQueue = new Queue<DirectorySearcher>(); 1322private readonly Queue<DirectorySearcher> _memberSearchersQueueOriginal = new Queue<DirectorySearcher>();

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\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Enumeration\FileSystemEnumerator.Unix.cs (1)

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

src\runtime\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\runtime\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.Xml (2)

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

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

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

1624freeLocalQueue = new Queue<LocalBuilder>();

System.Resources.Extensions (1)

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

279_pendingSerializationInfo ??= new();

System.Security.Cryptography.Xml (1)

System\Security\Cryptography\Xml\XmlDecryptionTransform.cs (1)

222Queue<ProcessElementWorkItem> encryptedDatasQueue = 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.Speech (1)

Internal\Synthesis\VoiceSynthesis.cs (1)

1763private Queue<Parameters> _pendingSpeakQueue = new();

System.Text.Json (2)

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

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

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

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

528 references to Queue

aspire (7)

Commands\AppHostLauncher.cs (4)

986var lines = new Queue<string>(maxLines); 987var guestCommandLines = new Queue<string>(maxLines); 1052var entries = new Queue<CliLogFormat.FileLogEntry>(maxLines); 1173private static void EnqueueBounded(Queue<string> lines, string line, int maxLines)

Interaction\ConsoleLogBufferContext.cs (1)

20private readonly Queue<(TextWriter Writer, string Message)> _bufferedMessages = new();

Packaging\PackageChannel.cs (1)

716var packagesToProcess = new Queue<string>(resolvedPackageIds);

Projects\PrebuiltAppHostServer.cs (1)

372var pending = new Queue<string>();

Aspire.Cli.Tests (9)

Commands\NewCommandTests.cs (1)

3007var selectedParents = new Queue<string?>([collidingParent.FullName, validParent.FullName]);

Commands\PublishCommandPromptingIntegrationTests.cs (1)

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

Interaction\ExtensionInteractionServiceTests.cs (2)

114var selections = new Queue<string?>([invalidPath, validPath]); 155var selections = new Queue<string?>([invalidPath, null]);

Mcp\ApiDocs\ApiDocsIndexServiceTests.cs (1)

610private readonly Queue<string?> _sitemapContents = new(sitemapContents);

Mcp\Docs\DocsIndexServiceTests.cs (1)

1396private readonly Queue<string?> _contents = new(contents);

ProfileCaptureOptionsTests.cs (1)

212var queue = new Queue<int>(ports.Length == 0 ? [5000, 5001, 5002] : ports);

Projects\GuestRuntimeTests.cs (1)

1462public Queue<int> ExitCodes { get; } = [];

TestServices\TestInteractionService.cs (1)

16private readonly Queue<(string Response, ResponseType Type)> _responses = new();

Aspire.Dashboard.Tests (2)

Model\DashboardClientTests.cs (1)

727private readonly Queue<T> _items;

tests\Shared\Telemetry\InMemoryTelemetryRepository.cs (1)

752Queue<OtlpTrace>? latestItems = context.LatestItemCount is not null

Aspire.Hosting (5)

ApplicationModel\CommandsConfigurationExtensions.cs (1)

470private readonly Queue<string> _lines = new();

ApplicationModel\ResourceExtensions.cs (1)

1555var toProcess = new Queue<IResource>();

Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)

1619Queue<ResourceLogLine>? tailBuffer = serverTailLineCount > 0 ? new Queue<ResourceLogLine>(serverTailLineCount) : null;

Backchannel\BackchannelLoggerProvider.cs (1)

11private readonly Queue<BackchannelLogEntry> _replayBuffer = new();

Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure (3)

AzureProvisioningController.cs (1)

1248var queue = new Queue<(IResource Resource, IAzureResource AzureResource)>();

Provisioning\Internal\DefaultArmClientProvider.cs (1)

369var pendingDeployments = new Queue<ResourceIdentifier>();

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure.Kubernetes (1)

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Azure.Tests (2)

ProvisioningTestHelpers.cs (2)

220public Queue<object?> DeploymentProbeResults { get; } = new(); 221public Queue<AzureDeploymentState?> DeploymentStates { get; } = new();

Aspire.Hosting.Docker (1)

src\Aspire.Hosting\Dcp\Process\ProcessOutputCapture.cs (1)

12private readonly Queue<string> _retainedLines = new();

Aspire.Hosting.Dotnet (1)

DotnetProjectResource.cs (1)

162var pendingSteps = new Queue<PipelineStep>();

Aspire.Hosting.TestUtilities (1)

Utils\TestProcessRunner.cs (1)

11private readonly Queue<TestProcessRun> _runs = [];

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

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

958private readonly Queue<string> _lines = [];

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\roslyn\src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

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

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

ILCompiler.Compiler (3)

Compiler\Dataflow\CompilerGeneratedCallGraph.cs (1)

56Queue<TypeSystemEntity> queue = new();

Compiler\DependencyAnalysis\ModuleInitializerListNode.cs (1)

66var modulesToExpand = new Queue<ModuleGraphNode>(allModules);

src\runtime\src\coreclr\tools\Common\Compiler\TypeMapMetadata.cs (1)

267Queue<(EcmaAssembly assembly, TypeDesc typeMapGroup)> assembliesToScan = [];

ILCompiler.MetadataTransform (1)

Internal\Metadata\NativeFormat\Writer\NativeMetadataWriter.cs (1)

274protected Queue<MetadataRecord> _queue = new Queue<MetadataRecord>();

ILCompiler.ReadyToRun (1)

src\runtime\src\coreclr\tools\Common\Compiler\TypeMapMetadata.cs (1)

267Queue<(EcmaAssembly assembly, TypeDesc typeMapGroup)> assembliesToScan = [];

illink (12)

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)

71if (!ProcessResponseFile(args, out var arguments)) 95readonly Queue<string> arguments; 116public Driver(Queue<string> arguments) 121public static bool ProcessResponseFile(string[] args, out Queue<string> result) 149public static void ParseResponseFile(TextReader reader, Queue<string> result)

Linker\InterfaceImplementor.cs (1)

45Queue<TypeDefinition> ifacesToCheck = new();

Linker\LinkContext.cs (1)

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

Linker\TypeMapHandler.cs (1)

319Queue<AssemblyDefinition> toVisit = new();

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

Hosting\WebAssemblyCallQueue.cs (1)

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

Microsoft.AspNetCore.Components.WebView (1)

Services\WebViewRenderer.cs (1)

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

Microsoft.AspNetCore.Http.Extensions (11)

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

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

Microsoft.AspNetCore.Razor.Utilities.Shared (6)

src\roslyn\src\Razor\src\Shared\Microsoft.AspNetCore.Razor.SharedUtilities\PooledObjects\QueuePool`1.cs (4)

8internal sealed partial class QueuePool<T> : CustomObjectPool<Queue<T>> 25public static PooledObject<Queue<T>> GetPooledObject() 28public static PooledObject<Queue<T>> GetPooledObject(out Queue<T> queue)

src\roslyn\src\Razor\src\Shared\Microsoft.AspNetCore.Razor.SharedUtilities\PooledObjects\QueuePool`1.Policy.cs (2)

31public override Queue<T> Create() => new(); 33public override bool Return(Queue<T> queue)

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

Internal\Http2\Http2FrameWriter.cs (1)

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

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

251private readonly Queue<Message> _messageQueue;

Microsoft.Build (7)

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

87private readonly Queue<PendingUnsubmittedBuildRequests> _unsubmittedRequests;

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

795var targetsToCheckForAfterTargets = new Queue<string>();

BackEnd\Components\Scheduler\Scheduler.cs (2)

124private Queue<TaskCompletionSource<int>> _pendingRequestCoresCallbacks; 2802Queue<SchedulableRequest> blockingRequests = new Queue<SchedulableRequest>();

BuildCheck\Checks\NoEnvironmentVariablePropertyCheck.cs (1)

24private readonly Queue<(string projectPath, BuildCheckDataContext<EnvironmentVariableCheckData>)> _buildCheckResults = new Queue<(string, BuildCheckDataContext<EnvironmentVariableCheckData>)>();

Graph\ProjectGraph.cs (2)

593var partialRoots = new Queue<ProjectGraphNode>(graphNodes.Count); 646var edgesToVisit = new Queue<ProjectGraphBuildRequest>();

Microsoft.Build.Tasks.CodeAnalysis (1)

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

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

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\roslyn\src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

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

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

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

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

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

Microsoft.CodeAnalysis.AnalyzerUtilities (18)

src\97c55a67c449f67c\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

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

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

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

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

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

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

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

Microsoft.CodeAnalysis.CodeStyle (15)

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

src\roslyn\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\roslyn\src\Analyzers\CSharp\Analyzers\UseCollectionExpression\CSharpUseCollectionExpressionForFluentDiagnosticAnalyzer.cs (1)

49nameof(Queue<>),

Microsoft.CodeAnalysis.CSharp.Features (1)

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

49nameof(Queue<>),

Microsoft.CodeAnalysis.CSharp.Workspaces (3)

FindSymbols\CSharpDeclaredSymbolInfoFactoryService.cs (2)

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

SyncedSource\FileBasedPrograms\VirtualProjectBuilder.cs (1)

340var filesToProcess = new Queue<string>();

Microsoft.CodeAnalysis.Features (1)

Shared\Utilities\ExtractTypeHelpers.cs (1)

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

Microsoft.CodeAnalysis.NetAnalyzers (6)

Microsoft.CodeQuality.Analyzers\QualityGuidelines\AvoidMultipleEnumerations\AvoidMultipleEnumerations.DataFlowOperationVisitor.cs (3)

169var queue = new Queue<IOperation>(); 274Queue<IOperation> queue) 301Queue<IOperation> queue)

src\8ce1f4f68b646e6d\GlobalFlowStateAnalysis.GlobalFlowStateAnalysisValueSetDomain.cs (1)

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

src\sdk\src\Microsoft.CodeAnalysis.NetAnalyzers\src\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)

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

src\sdk\src\Microsoft.CodeAnalysis.NetAnalyzers\src\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)

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

Microsoft.CodeAnalysis.ResxSourceGenerator (17)

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

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

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

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

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

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

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

Differencing\EditScript.cs (1)

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

Log\WorkspaceStructureLogger.cs (1)

273var namespaces = new Queue<INamespaceSymbol>();

Shared\Extensions\INamespaceSymbolExtensions.cs (2)

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

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

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

Microsoft.DotNet.ApiCompatibility (1)

Mapping\AssemblyMapper.cs (1)

51Queue<INamespaceSymbol> queue = new();

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

CreateTrimDependencyGroups.cs (1)

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

Microsoft.DotNet.HotReload.Watch (1)

Build\ProjectGraphUtilities.cs (1)

125var queue = new Queue<ProjectGraphNode>();

Microsoft.DotNet.PackageValidation (2)

Package.cs (1)

228Queue<NuGetFramework> tfmQueue = new(AssemblyReferences.Keys);

Validators\CompatibleFrameworkInPackageValidator.cs (1)

39Queue<(NuGetFramework, IReadOnlyList<ContentItem>)> compileAssetsQueue = new();

Microsoft.DotNet.ProjectTools (1)

src\sdk\src\Cli\Microsoft.DotNet.FileBasedPrograms\VirtualProjectBuilder.cs (1)

346var filesToProcess = new Queue<string>();

Microsoft.Extensions.AI (1)

ChatReduction\MessageCountingChatReducer.cs (1)

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

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

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.GetJsonTypeInfo.g.cs (1)

272if (type == typeof(global::System.Collections.Generic.Queue<double>))

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.QueueDouble.g.cs (10)

parent\parent\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.AI.Tests (6)

ChatCompletion\FunctionInvokingChatClientApprovalsTests.cs (6)

1031Func<Queue<List<ChatMessage>>> expectedDownstreamClientInput = () => new Queue<List<ChatMessage>>( 1045Func<Queue<List<ChatMessage>>> downstreamClientOutput = () => new Queue<List<ChatMessage>>( 1951Queue<List<ChatMessage>> downstreamClientOutput, 1953Queue<List<ChatMessage>>? expectedDownstreamClientInput = null, 2039Queue<List<ChatMessage>> downstreamClientOutput, 2041Queue<List<ChatMessage>>? expectedDownstreamClientInput = null,

Microsoft.Extensions.Configuration.Binder.SourceGeneration (1)

ConfigurationBindingGenerator.Parser.cs (1)

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

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

Logging\FakeLogCollectorTests.LogEnumeration.cs (2)

141private static bool ContainsNonContinuousSequence(IEnumerable<string> orderedEnumeration, Queue<string> sequence) 160Queue<string> sequence,

Microsoft.Extensions.Http.Diagnostics (1)

Http\HttpDependencyMetadataResolver.cs (1)

200Queue<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)

293private 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.TemplateEngine.Cli (1)

Commands\Example.cs (1)

58Queue<Command> probes = new();

Microsoft.TemplateEngine.Utils (3)

DirectedGraph.cs (2)

52Queue<T> noDependenciesQueue = new(inDegreeLookup.Where(kp => kp.Value == 0).Select(kp => kp.Key)); 98Queue<T> directDependents = new(vertices);

EnumerableExtensions.cs (1)

62public static void AddRange<T>(this Queue<T> queue, IEnumerable<T> elements)

Microsoft.TestPlatform.CoreUtilities (1)

Utilities\JobQueue.cs (1)

36private readonly Queue<Job<T>> _jobsQueue;

Microsoft.TestPlatform.CrossPlatEngine (1)

Client\Parallel\ParallelOperationManager.cs (1)

61private readonly Queue<ProviderSpecificWorkload<TWorkload>> _pendingWorkloads = new();

Microsoft.Win32.SystemEvents (1)

Microsoft\Win32\SystemEvents.cs (1)

36private static volatile Queue<Delegate>? s_threadCallbackList; // list of Delegates

MSBuild (1)

OutOfProcTaskHostNode.cs (1)

82private Queue<INodePacket> _receivedPackets;

MSBuild.Coordinator (3)

CoordinatorServer.cs (2)

453Queue<BuildGrant> pendingNotifications = new(newlyGranted.Length); 488private void EnqueueNewlyGrantedNotifications(Queue<BuildGrant> pendingNotifications, ImmutableArray<BuildGrant> newlyGranted)

NodeBudgetManager.cs (1)

17private readonly Queue<BuildGrant> _waitQueue = new();

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

NuGet.CommandLine.XPlat (3)

Utility\TableParser.cs (3)

42var columnQueues = new Dictionary<int, Queue<FormattedCell>>(); 54var queue = new Queue<FormattedCell>(); 99if (columnQueues.TryGetValue(colIndex, out var thisColumnQueue)) // we have at least one remaining value for this column

NuGet.Commands (11)

RestoreCommand\DependencyGraphResolver.cs (3)

340Queue<(LibraryDependencyIndex, LibraryRangeIndex, GraphNode<RemoteResolveResult>)> itemsToFlatten = new(); 930Queue<DependencyGraphItem> dependencyGraphItemQueue = new(DependencyGraphItemQueueSize); 1152Queue<DependencyGraphItem> newDependencyGraphItemQueue = new(DependencyGraphItemQueueSize);

RestoreCommand\LockFileBuilder.cs (3)

534Queue<GraphNode<RemoteResolveResult>> queue = new Queue<GraphNode<RemoteResolveResult>>(); 609/// <param name="queue">Reusable <see cref="Queue{GraphNode{T}}" /> for graph traversal algorithm.</param> 613private static IEnumerable<GraphNode<T>> EnumerateNodesForDependencyChecks<T>(HashSet<GraphNode<T>> visitedNodes, Queue<GraphNode<T>> queue, GraphNode<T> rootNode, GraphNode<T> graphNode)

RestoreCommand\Logging\TransitiveNoWarnUtils.cs (2)

92var queue = new Queue<DependencyNode>(); 293Queue<DependencyNode> queue,

RestoreCommand\RestoreRunner.cs (2)

69var requests = new Queue<RestoreSummaryRequest>(restoreRequests); 135var requests = new Queue<RestoreSummaryRequest>(restoreRequests);

RestoreCommand\Utility\IncludeFlagUtils.cs (1)

81var nodeQueue = new Queue<DependencyNode>(1);

NuGet.DependencyResolver.Core (15)

GraphModel\GraphOperations.cs (15)

531var queue = Cache<TItem>.RentQueue(); 553var queue = Cache<TItem, TState>.RentQueue(); 573var queue = Cache<TItem>.RentQueue(); 594var queue = Cache<TItem>.RentQueue(); 619var queue = Cache<TItem>.RentQueue(); 642private static void AddInnerNodesToQueue<TItem, TState>(IList<GraphNode<TItem>> innerNodes, Queue<NodeWithState<TItem, TState>> queue, TState innerState) 652private static void AddInnerNodesToQueue<TItem>(IList<GraphNode<TItem>> innerNodes, Queue<GraphNode<TItem>> queue) 689private static Queue<NodeWithState<TItem, TState>> _queue; 692public static Queue<NodeWithState<TItem, TState>> RentQueue() 694var queue = _queue; 704public static void ReleaseQueue(Queue<NodeWithState<TItem, TState>> queue) 718private static Queue<GraphNode<TItem>> _queue; 724public static Queue<GraphNode<TItem>> RentQueue() 726var queue = _queue; 736public static void ReleaseQueue(Queue<GraphNode<TItem>> queue)

NuGet.PackageManagement (8)

NuGetPackageManager.cs (1)

2060var results = new Queue<KeyValuePair<SourceRepository, Task<bool>>>();

PackageDownloader.cs (1)

84var groups = new Queue<List<SourceRepository>>();

PackagePreFetcher.cs (1)

60var toDownload = new Queue<NuGetProjectAction>();

Resolution\PrunePackageTree.cs (1)

79var queue = new Queue<SourcePackageDependencyInfo>();

Resolution\ResolverGather.cs (1)

28private readonly Queue<GatherRequest> _gatherRequests = new Queue<GatherRequest>();

Resolution\UninstallResolver.cs (1)

105var breathFirstSearchQueue = new Queue<PackageIdentity>();

Utility\XElementExtensions.cs (2)

130var pendingComments = new Queue<XComment>(); 373private static void AddContents<T>(Queue<T> pendingComments, Action<T> action)

NuGet.ProjectModel (1)

ProjectLockFile\PackagesLockFileUtilities.cs (1)

185var queue = new Queue<Tuple<string, string>>();

NuGet.Resolver (2)

ResolverUtility.cs (2)

215var queue = new Queue<ResolverPackage>(); 419var queue = new Queue<QueueNode>();

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)

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

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

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

Roslyn.Diagnostics.Analyzers (17)

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

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

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

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

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

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

SelectTests (1)

GraphAffectedProjects.cs (1)

408var queue = new Queue<string>();

Shared.Tests (15)

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.GetJsonTypeInfo.g.cs (1)

272if (type == typeof(global::System.Collections.Generic.Queue<double>))

Generated\Basic.CompilerLog.Util\Basic.CompilerLog.Util.Impl.BasicGeneratedFilesAnalyzerReference\TestTypesContext.QueueDouble.g.cs (10)

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)

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

System (1)

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

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

System.CodeDom (1)

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

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

System.Collections (3)

src\runtime\artifacts\obj\System.Collections\Release\net11.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.CommandLine (1)

EnumerableExtensions.cs (1)

18var queue = new Queue<T>();

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.DirectoryServices.AccountManagement (6)

System\DirectoryServices\AccountManagement\AD\ADDNLinkedAttrSet.cs (6)

1287private readonly Queue<IEnumerable> _membersQueue = new Queue<IEnumerable>(); 1289private readonly Queue<IEnumerable> _originalMembers = new Queue<IEnumerable>(); // the membership we started off with (before recursing) 1321private readonly Queue<DirectorySearcher> _memberSearchersQueue = new Queue<DirectorySearcher>(); 1322private readonly Queue<DirectorySearcher> _memberSearchersQueueOriginal = new Queue<DirectorySearcher>(); 1371public Queue<IEnumerable> membersQueue; 1387public Queue<DirectorySearcher> memberSearcherQueue;

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)

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

System.Private.CoreLib (9)

src\runtime\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\runtime\src\libraries\System.Private.CoreLib\src\System\Collections\Generic\QueueDebugView.cs (2)

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

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

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

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

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

src\runtime\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\runtime\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.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; 1610public void AddToFreeLocals(Dictionary<(Type, string), Queue<LocalBuilder>> freeLocals) 1615Queue<LocalBuilder>? freeLocalQueue;

System.Resources.Extensions (2)

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

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

System.Security.Cryptography.Xml (1)

System\Security\Cryptography\Xml\XmlDecryptionTransform.cs (1)

222Queue<ProcessElementWorkItem> encryptedDatasQueue = new();

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

Internal\Synthesis\VoiceSynthesis.cs (1)

1763private Queue<Parameters> _pendingSpeakQueue = new();

System.Text.Json (8)

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

132else 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)

271/// Creates serialization metadata for types assignable to <see cref="Queue{T}"/>. 282where TCollection : Queue<TElement> 307/// 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)

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

JsonSourceGenerator.Parser.cs (1)

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

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

283private 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