Queue

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)

1233private class HistoryQueue : Queue<ManipulationState> 1327private class SmoothingQueue : Queue<ManipulationState>

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

Linker.Dataflow\CompilerGeneratedCallGraph.cs (1)

47 Queue<IMemberDefinition> queue = new ();

Linker.Steps\MarkStep.cs (3)

213 _methods = new Queue<(MethodDefinition, DependencyInfo)> (); 215 _assemblyLevelAttributes = new Queue<AttributeProviderPair> (); 216 _lateMarkedAttributes = new Queue<(AttributeProviderPair, DependencyInfo, MessageOrigin)> ();

Linker\Driver.cs (1)

101 result = new Queue<string> ();

Linker\InterfaceImplementor.cs (1)

43 Queue<TypeDefinition> ifacesToCheck = new ();

Linker\LinkContext.cs (1)

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

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)

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

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

543_pendingRequestCoresCallbacks = new Queue<TaskCompletionSource<int>>(); 2636Queue<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.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)

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

Microsoft.CodeAnalysis.Test.Utilities (1)

Compilation\IRuntimeEnvironment.cs (1)

155var 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.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)

171var 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)

187_receivedPackets = new Queue<INodePacket>();

MSBuildTaskHost (1)

OutOfProcTaskHostNode.cs (1)

187_receivedPackets = new Queue<INodePacket>();

PresentationCore (4)

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

1239Queue<StrokeInfo> _renderCompleteDRThreadStrokeInfoList = new Queue<StrokeInfo>();

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

3666Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();

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

73_eventQueue = new Queue<WeakReference>();

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

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

PresentationFramework (3)

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

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

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

492_recyclableContainers = new Queue<DependencyObject>(); 2805private Queue<DependencyObject> _recyclableContainers = new Queue<DependencyObject>();

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)

148var 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.Formats.Nrbf (1)

System\Formats\Nrbf\BinaryArrayRecord.cs (1)

236(jaggedArrayRecords ??= new()).Enqueue((BinaryArrayRecord)nestedArrayRecord);

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)

164Queue<TSource> queue = new();

System\Linq\Take.cs (2)

112queue = new Queue<TSource>(); 162queue = 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)

148var 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\Core\BinaryFormat\Deserializer\Deserializer.cs (1)

275_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)

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

Blocks\BroadcastBlock.cs (1)

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

Blocks\JoinBlock.cs (1)

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

System.Windows.Forms (3)

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

6391_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)

50_resolvedTokensPendingProcessing = new Queue<NameFixupToken>();

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

101_buffer = new Queue<XamlNode>();

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

51_readNodesQueue = new Queue<XamlScannerNode>();

System\Xaml\XamlNodeQueue.cs (1)

29_nodeQueue = new Queue<XamlNode>();

System\Xaml\XamlObjectReader.cs (1)

2485pendingNameScopes = new Queue<NameScopeMarkupInfo>();

VBCSCompiler.UnitTests (1)

TestableClientConnectionHost.cs (1)

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

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

Linker.Dataflow\CompilerGeneratedCallGraph.cs (1)

47 Queue<IMemberDefinition> queue = new ();

Linker.Steps\MarkStep.cs (3)

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

Linker\Driver.cs (5)

61 if (!ProcessResponseFile (args, out var arguments)) { 78 readonly Queue<string> arguments; 94 public Driver (Queue<string> arguments) 99 public static bool ProcessResponseFile (string[] args, out Queue<string> result) 120 public static void ParseResponseFile (TextReader reader, Queue<string> result)

Linker\InterfaceImplementor.cs (1)

43 Queue<TypeDefinition> ifacesToCheck = new ();

Linker\LinkContext.cs (1)

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

Microsoft.AspNetCore.Components (2)

Rendering\RenderBatchBuilder.cs (2)

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

Microsoft.AspNetCore.Components.Endpoints (11)

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

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

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

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

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

Binding\FormDataMapperTests.cs (3)

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

Microsoft.AspNetCore.Components.WebAssembly (1)

Hosting\WebAssemblyCallQueue.cs (1)

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

Microsoft.AspNetCore.Components.WebView (1)

Services\WebViewRenderer.cs (1)

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

Microsoft.AspNetCore.Http.Extensions (11)

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

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

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

Internal\Http2\Http2FrameWriter.cs (1)

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

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

Mocks\MockHttpContextFactory.cs (1)

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

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

251private readonly Queue<Message> _messageQueue;

Microsoft.Build (7)

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

76private readonly Queue<PendingUnsubmittedBuildRequests> _unsubmittedRequests;

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

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

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

114private Queue<TaskCompletionSource<int>> _pendingRequestCoresCallbacks; 2636Queue<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)

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)

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

Microsoft.CodeAnalysis.Test.Utilities (1)

Compilation\IRuntimeEnvironment.cs (1)

155var toVisit = new Queue<Compilation>(FindDirectReferencedCompilations(original));

Microsoft.CodeAnalysis.UnitTests (1)

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

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

Microsoft.CodeAnalysis.VisualBasic (11)

Binding\Binder_Lookup.vb (7)

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

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

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

Microsoft.CodeAnalysis.Workspaces (18)

Differencing\EditScript.cs (1)

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

Shared\Extensions\INamespaceSymbolExtensions.cs (2)

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

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

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

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

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

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

Microsoft.DotNet.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)

797yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1279[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.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)

171var 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)

86private Queue<INodePacket> _receivedPackets;

MSBuildTaskHost (1)

OutOfProcTaskHostNode.cs (1)

86private 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)

1239Queue<StrokeInfo> _renderCompleteDRThreadStrokeInfoList = new Queue<StrokeInfo>();

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

3666Queue<RawStylusInputReport> _queueStylusEvents = new Queue<RawStylusInputReport>();

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

917private Queue<WeakReference> _eventQueue;

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

261private Queue<DUCE.Channel> _freeSyncChannels;

PresentationFramework (2)

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

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

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

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

RunTests (1)

ProcessUtil.cs (1)

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

Shared.Tests (4)

JsonSchemaExporter\TestTypes.cs (2)

797yield return new TestData<Queue<double>>(new([1.1, 2.2, 3.3]), """{"type":["array","null"],"items":{"type":"number"}}"""); 1279[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)

148var 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.Formats.Nrbf (1)

System\Formats\Nrbf\BinaryArrayRecord.cs (1)

199Queue<BinaryArrayRecord>? jaggedArrayRecords = null;

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)

164Queue<TSource> queue = new();

System\Linq\Take.cs (1)

100Queue<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.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)

148var 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\Core\BinaryFormat\Deserializer\Deserializer.cs (2)

75private Queue<PendingSerializationInfo>? _pendingSerializationInfo; 91private 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)

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

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

Blocks\BroadcastBlock.cs (1)

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

Blocks\JoinBlock.cs (1)

493private readonly Queue<T>? _messages;

System.Windows.Forms (3)

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

270private 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)

1058private static float GetVelocity(Queue<ManipulationState> queue, PropertyAccessor accessor) 1075private static float CalculateWeightedMovingAverage(Queue<ManipulationState> queue, PropertyAccessor accessor) 1137private static float CalculateMovingAverage(Queue<ManipulationState> queue, PropertyAccessor accessor, float defaultValue)

System.Xaml (6)

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

32Queue<NameFixupToken> _resolvedTokensPendingProcessing;

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

23Queue<XamlNode> _buffer;

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

38Queue<XamlScannerNode> _readNodesQueue;

System\Xaml\XamlNodeQueue.cs (1)

19Queue<XamlNode> _nodeQueue;

System\Xaml\XamlObjectReader.cs (2)

2474Queue<NameScopeMarkupInfo> pendingNameScopes; 2522public Queue<NameScopeMarkupInfo> PendingNameScopes

VBCSCompiler.UnitTests (1)

TestableClientConnectionHost.cs (1)

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