3 types derived from Queue
System.Private.CoreLib (1)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)
6899private 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>
157 instantiations of Queue
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>();
illink (7)
Metrics (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Metrics.Legacy (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
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.Endpoints.Tests (1)
Binding\FormDataMapperTests.cs (1)
769var expected = new Queue<int>(new[] { 10, 11, 12, 13, 14, 15, 16, 17, 18, 19 });
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 (1)
src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\QueueBufferAdapter.cs (1)
8public static Queue<TElement> CreateBuffer() => new();
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)
256_messageQueue = new Queue<Message>();
Microsoft.Build (7)
BackEnd\Components\BuildRequestEngine\BuildRequestEngine.cs (1)
136_unsubmittedRequests = new Queue<PendingUnsubmittedBuildRequests>();
BackEnd\Components\RequestBuilder\TargetBuilder.cs (1)
794var targetsToCheckForAfterTargets = new Queue<string>();
BackEnd\Components\Scheduler\Scheduler.cs (2)
542_pendingRequestCoresCallbacks = new Queue<TaskCompletionSource<int>>(); 2632Queue<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)
564var partialRoots = new Queue<ProjectGraphNode>(graphNodes.Count); 617var edgesToVisit = new Queue<ProjectGraphBuildRequest>();
Microsoft.Build.Tasks.CodeAnalysis (1)
Vbc.cs (1)
35private 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 (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)
498var 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)
618var queue = new Queue<SyntaxNodeOrToken>(); 701var 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\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
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)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var 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)
104Queue<NamespaceSymbol> namespaces = new Queue<NamespaceSymbol>();
Microsoft.CodeAnalysis.EditorFeatures (1)
IntelliSense\ViewTextSpan.cs (1)
110var sourceSpans = new Queue<SnapshotSpan>(start.MapToSourceSnapshots(span));
Microsoft.CodeAnalysis.ExpressionEvaluator.ResultProvider.Utilities (1)
Debugger\Engine\DkmWorkList.cs (1)
31_workList = new Queue<Action>(1);
Microsoft.CodeAnalysis.Features (1)
Shared\Utilities\ExtractTypeHelpers.cs (1)
142var unanalyzedTypeParameters = new Queue<ITypeParameterSymbol>(directlyReferencedTypeParameters);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Microsoft.CodeAnalysis.Test.Utilities (1)
CompilationVerifier.cs (1)
986var 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.AsmDiff (2)
AssemblySet.cs (2)
56var queue = new Queue<IAssemblyReference>(metadataHost.LoadedUnits.OfType<IAssemblyReference>()); 158var queue = new Queue<IAssemblyReference>(assemblies);
Microsoft.DotNet.Build.Tasks.Packaging (1)
CreateTrimDependencyGroups.cs (1)
85var newDependencyGroups = new Queue<TaskItemPackageDependencyGroup>();
Microsoft.Extensions.Http.Diagnostics (1)
Http\DownstreamDependencyMetadataManager.cs (1)
190Queue<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)
170var queue = new Queue<ISymbol>();
MoveStaticMembers\StaticMemberSelectionViewModel.cs (1)
85var queue = new Queue<ISymbol>();
PullMemberUp\MainDialog\BaseTypeTreeNodeViewModel.cs (1)
50var queue = new Queue<BaseTypeTreeNodeViewModel>();
MSBuild (1)
OutOfProcTaskHostNode.cs (1)
186_receivedPackets = new Queue<INodePacket>();
MSBuildTaskHost (1)
OutOfProcTaskHostNode.cs (1)
186_receivedPackets = new Queue<INodePacket>();
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)
3679private Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();
System\Windows\Media\Animation\TimeManager.cs (1)
58_eventQueue = new Queue<WeakReference>();
System\Windows\Media\ChannelManager.cs (1)
136_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)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
RunTests (1)
ProcessUtil.cs (1)
75var toVisit = new Queue<Process>();
Shared.Tests (1)
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)
128Queue<Type> genericTypeArguments = new Queue<Type>(type.GetGenericArguments()); 303Queue<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)
39private readonly Queue<SerialStreamIORequest> _readQueue = new(); 41private readonly Queue<SerialStreamIORequest> _writeQueue = new();
System.Linq (3)
System\Linq\ElementAt.cs (1)
160Queue<TSource> queue = new();
System\Linq\Take.cs (2)
121queue = new Queue<TSource>(); 171queue = 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)
150_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)
1135Queue<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)
1594freeLocalQueue = new Queue<LocalBuilder>();
System.Resources.Extensions (1)
System\Resources\Extensions\BinaryFormat\Deserializer\Deserializer.cs (1)
279_pendingSerializationInfo ??= new();
System.Text.Json (2)
src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)
102var 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)
102var 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)
6430_threadCallbackList ??= new Queue<ThreadMethodEntry>();
System\Windows\Forms\Dialogs\TaskDialog\TaskDialog.cs (1)
79private 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)
170var operationsToProcess = new Queue<IOperation>();
Text.Analyzers (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
VBCSCompiler.UnitTests (1)
TestableClientConnectionHost.cs (1)
18private readonly Queue<Func<Task<IClientConnection>>> _waitingTasks = new Queue<Func<Task<IClientConnection>>>();
329 references to Queue
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)
illink (11)
Metrics (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Metrics.Legacy (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
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)
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;
src\Components\Endpoints\src\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.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 (7)
BackEnd\Components\BuildRequestEngine\BuildRequestEngine.cs (1)
76private readonly Queue<PendingUnsubmittedBuildRequests> _unsubmittedRequests;
BackEnd\Components\RequestBuilder\TargetBuilder.cs (1)
794var targetsToCheckForAfterTargets = new Queue<string>();
BackEnd\Components\Scheduler\Scheduler.cs (2)
113private Queue<TaskCompletionSource<int>> _pendingRequestCoresCallbacks; 2632Queue<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)
564var partialRoots = new Queue<ProjectGraphNode>(graphNodes.Count); 617var edgesToVisit = new Queue<ProjectGraphBuildRequest>();
Microsoft.Build.Tasks.CodeAnalysis (1)
Vbc.cs (1)
35private 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)
498var typesToIndex = new Queue<ITypeDefinition>(); 515void 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)
519public readonly Queue<SyntaxNodeOrToken>? OldNodes; 520public readonly Queue<SyntaxNodeOrToken>? NewNodes; 522internal ChangeRecord(TextChangeRange range, Queue<SyntaxNodeOrToken>? oldNodes, Queue<SyntaxNodeOrToken>? newNodes) 533var removedNodes = CopyFirst(_oldNodes, oldNodeCount); 554var removedNodes = CopyFirst(_oldNodes, oldNodeCount); 557var insertedNodes = CopyFirst(_newNodes, newNodeCount); 566var insertedNodes = CopyFirst(_newNodes, newNodeCount); 616Queue<SyntaxNodeOrToken> CreateQueue(SyntaxNodeOrToken nodeOrToken) 618var queue = new Queue<SyntaxNodeOrToken>(); 649private static TextSpan GetSpan(Queue<SyntaxNodeOrToken> queue, int first, int length) 674private static Queue<SyntaxNodeOrToken>? Combine(Queue<SyntaxNodeOrToken>? first, Queue<SyntaxNodeOrToken>? next) 694private static Queue<SyntaxNodeOrToken>? CopyFirst(Stack<SyntaxNodeOrToken> stack, int n) 701var queue = new Queue<SyntaxNodeOrToken>(n); 819private static string GetText(Queue<SyntaxNodeOrToken>? queue) 834private static void CopyText(Queue<SyntaxNodeOrToken>? queue, StringBuilder builder)
Microsoft.CodeAnalysis.Analyzers (4)
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)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Microsoft.CodeAnalysis.AnalyzerUtilities (3)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
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)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Microsoft.CodeAnalysis.CodeStyle (15)
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)
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)
50nameof(Queue<int>),
Microsoft.CodeAnalysis.CSharp.Features (1)
src\Analyzers\CSharp\Analyzers\UseCollectionExpression\CSharpUseCollectionExpressionForFluentDiagnosticAnalyzer.cs (1)
50nameof(Queue<int>),
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)
104Queue<NamespaceSymbol> namespaces = new Queue<NamespaceSymbol>();
Microsoft.CodeAnalysis.CSharp.Workspaces (1)
FindSymbols\CSharpDeclaredSymbolInfoFactoryService.cs (1)
169using var pooledQueue = SharedPools.Default<Queue<SyntaxNodeOrToken>>().GetPooledObject();
Microsoft.CodeAnalysis.EditorFeatures (1)
IntelliSense\ViewTextSpan.cs (1)
110var sourceSpans = new Queue<SnapshotSpan>(start.MapToSourceSnapshots(span));
Microsoft.CodeAnalysis.ExpressionEvaluator.ResultProvider.Utilities (1)
Debugger\Engine\DkmWorkList.cs (1)
24private readonly Queue<Action> _workList;
Microsoft.CodeAnalysis.Features (1)
Shared\Utilities\ExtractTypeHelpers.cs (1)
142var unanalyzedTypeParameters = new Queue<ITypeParameterSymbol>(directlyReferencedTypeParameters);
Microsoft.CodeAnalysis.ResxSourceGenerator (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Microsoft.CodeAnalysis.Test.Utilities (1)
CompilationVerifier.cs (1)
986var 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)
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)
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (15)
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)
Microsoft.DotNet.AsmDiff (2)
AssemblySet.cs (2)
56var queue = new Queue<IAssemblyReference>(metadataHost.LoadedUnits.OfType<IAssemblyReference>()); 158var queue = new Queue<IAssemblyReference>(assemblies);
Microsoft.DotNet.Build.Tasks.Packaging (1)
CreateTrimDependencyGroups.cs (1)
85var newDependencyGroups = new Queue<TaskItemPackageDependencyGroup>();
Microsoft.Extensions.AI.Abstractions.Tests (2)
test\Shared\JsonSchemaExporter\TestTypes.cs (2)
805yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1287[JsonSerializable(typeof(Queue<double>))]
Microsoft.Extensions.Http.Diagnostics (1)
Http\DownstreamDependencyMetadataManager.cs (1)
190Queue<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)
170var 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>());
MSBuild (1)
OutOfProcTaskHostNode.cs (1)
85private Queue<INodePacket> _receivedPackets;
MSBuildTaskHost (1)
OutOfProcTaskHostNode.cs (1)
85private Queue<INodePacket> _receivedPackets;
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)
3679private Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();
System\Windows\Media\Animation\TimeManager.cs (1)
899private Queue<WeakReference> _eventQueue;
System\Windows\Media\ChannelManager.cs (1)
241private 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 (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
RunTests (1)
ProcessUtil.cs (1)
75var toVisit = new Queue<Process>();
Shared.Tests (4)
JsonSchemaExporter\TestTypes.cs (2)
805yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1287[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)
9[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)
128Queue<Type> genericTypeArguments = new Queue<Type>(type.GetGenericArguments()); 219private static void WriteGenericType(StringBuilder typeName, Type type, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 241private static void WriteGenericTypeName(StringBuilder typeName, Type type, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 256private static void WriteTypeArgumentsString(StringBuilder typeName, int argumentsCount, bool isDefinition, Queue<Type> genericTypeArguments, bool formatGenericName) 303Queue<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)
39private readonly Queue<SerialStreamIORequest> _readQueue = new(); 41private readonly Queue<SerialStreamIORequest> _writeQueue = new(); 848private static int DoIORequest(Queue<SerialStreamIORequest> q, object queueLock, RequestProcessor op) 1017private 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)
109Queue<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 (8)
src\libraries\System.Private.CoreLib\src\System\Collections\Generic\Queue.cs (3)
363/// Sets the capacity of a <see cref="Queue{T}"/> object to the specified number of entries. 424private readonly Queue<T> _q; 429internal Enumerator(Queue<T> q)
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)
1135Queue<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; 1580public void AddToFreeLocals(Dictionary<(Type, string), Queue<LocalBuilder>> freeLocals) 1585Queue<LocalBuilder>? freeLocalQueue;
System.Resources.Extensions (2)
System\Resources\Extensions\BinaryFormat\Deserializer\Deserializer.cs (2)
77private Queue<PendingSerializationInfo>? _pendingSerializationInfo; 93private readonly Queue<SerializationRecordId> _pendingCompletions = [];
System.Text.Json (8)
src\libraries\System.Text.Json\Common\JsonHelpers.cs (1)
102var 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 (4)
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 (2)
32public static bool TryDequeue<T>(this Queue<T> queue, [NotNullWhen(true)] out T? result) 102var 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)
269private Queue<ThreadMethodEntry>? _threadCallbackList;
System\Windows\Forms\Dialogs\TaskDialog\TaskDialog.cs (1)
79private 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 (1)
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
Text.Analyzers (2)
src\RoslynAnalyzers\Utilities\Compiler\CodeMetrics\MetricsHelper.cs (1)
203var nodesToProcess = new Queue<SyntaxNode>();
src\RoslynAnalyzers\Utilities\Compiler\Extensions\IOperationExtensions.cs (1)
170var operationsToProcess = new Queue<IOperation>();
VBCSCompiler.UnitTests (1)
TestableClientConnectionHost.cs (1)
18private readonly Queue<Func<Task<IClientConnection>>> _waitingTasks = new Queue<Func<Task<IClientConnection>>>();