Queue

2 types derived from Queue

System.Windows.Input.Manipulations (2)

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

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

110 instantiations of Queue

Amg88xx (1)

Amg88xx.cs (1)

432var flagRegisters = new Queue<byte>();

Amg88xx.Tests (2)

I2cTestDevice.cs (2)

12public Queue<byte> DataToRead { get; } = new Queue<byte>(); 13public Queue<byte> DataWritten { get; } = new Queue<byte>();

Arduino (1)

FirmataDevice.cs (1)

92_dataQueue = new Queue<byte>(1024);

dotnet (2)

Installer\Windows\PipeStreamSetupLogger.cs (1)

22private readonly Queue<string> _messageQueue = new Queue<string>();

Telemetry\PersistenceChannel\FixedSizeQueue.cs (1)

15private readonly Queue<T> _queue = new Queue<T>();

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

dotnet-watch (1)

HotReload\HotReloadProfileReader.cs (1)

17var queue = new Queue<ProjectGraphNode>(projectGraph.EntryPointNodes);

Iot.Device.Bindings (5)

Amg88xx.cs (1)

432var flagRegisters = new Queue<byte>();

FirmataDevice.cs (1)

92_dataQueue = new Queue<byte>(1024);

NmeaUdpServer.cs (1)

179_data = new Queue<byte>();

SentenceCache.cs (2)

44_lastRouteSentences = new Queue<RoutePart>(); 45_lastSatelliteInfos = new Queue<SatellitesInView>();

Microsoft.AspNetCore.Components (2)

Rendering\RenderBatchBuilder.cs (2)

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

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)

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

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

Internal\Http2\Http2FrameWriter.cs (1)

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

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

256_messageQueue = new Queue<Message>();

Microsoft.Build (6)

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

135_unsubmittedRequests = new Queue<PendingUnsubmittedBuildRequests>();

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

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

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

531_pendingRequestCoresCallbacks = new Queue<TaskCompletionSource<int>>(); 2578Queue<SchedulableRequest> blockingRequests = new Queue<SchedulableRequest>();

Graph\ProjectGraph.cs (2)

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

Microsoft.Build.Engine (6)

Collections\DualQueue.cs (2)

32this.backingQueueA = new Queue<T>(); 33this.backingQueueB = new Queue<T>();

Engine\Node.cs (1)

40this.buildRequests = new Queue<BuildRequest>();

Engine\TaskWorkerThread.cs (2)

52this.workerThreadQueue = new Queue<TaskWorkerThread>(); 54this.workItemQueue = new Queue<TaskExecutionState>();

LocalProvider\LocalNodeProvider.cs (1)

80this.nodesToLaunch = new Queue<int>();

Microsoft.Cci.Extensions (2)

Extensions\CSharp\CSharpCciExtensions.cs (2)

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

Microsoft.DotNet.ApiCompatibility (1)

Abstractions\Mappers\AssemblyMapper.cs (1)

64Queue<INamespaceSymbol> queue = new();

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)

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

Microsoft.DotNet.PackageValidation (1)

Validators\CompatibleFrameworkInPackageValidator.cs (1)

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

Microsoft.Extensions.Logging.Console (1)

ConsoleLoggerProcessor.cs (1)

65_messageQueue = new Queue<LogMessageEntry>();

Microsoft.ML.Core (2)

Data\Repository.cs (1)

305_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.StandardTrainers (1)

Optimizer\OptimizationMonitor.cs (1)

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

Microsoft.ML.Transforms (1)

Expression\Lexer.cs (1)

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

Microsoft.TemplateEngine.Cli (1)

Commands\Example.cs (1)

163Queue<Command> probes = new Queue<Command>();

MSBuild (1)

OutOfProcTaskHostNode.cs (1)

178_receivedPackets = new Queue<INodePacket>();

MSBuildTaskHost (1)

OutOfProcTaskHostNode.cs (1)

178_receivedPackets = new Queue<INodePacket>();

Nmea0183 (3)

NmeaUdpServer.cs (1)

179_data = new Queue<byte>();

SentenceCache.cs (2)

44_lastRouteSentences = new Queue<RoutePart>(); 45_lastSatelliteInfos = new Queue<SatellitesInView>();

PresentationCore (4)

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

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

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

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

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

74_eventQueue = new Queue<WeakReference>();

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

157_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>(); 2809private Queue<DependencyObject> _recyclableContainers = new Queue<DependencyObject>();

System.CodeDom (1)

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

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

System.Collections (2)

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

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

161Queue<TSource> queue = new();

System\Linq\Take.cs (2)

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

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

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

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

System.Private.CoreLib (1)

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

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

System.Private.DataContractSerialization (3)

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

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

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

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

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

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

System.Private.ServiceModel (10)

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

29_readerQueue = new Queue<IQueueReader>();

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

1075private 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.Private.Xml (2)

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

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

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

1592freeLocalQueue = new Queue<LocalBuilder>();

System.Runtime.Serialization.Formatters (1)

System\Runtime\Serialization\Formatters\Binary\BinaryObjectWriter.cs (1)

66_objectQueue = new Queue<object>();

System.Text.Json (2)

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

379var next = new Queue<T>();

System\Text\Json\Serialization\JsonSerializer.Read.Stream.cs (1)

417ObjectCreator = static () => new Queue<TValue>(),

System.Text.Json.SourceGeneration (1)

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

379var next = new Queue<T>();

System.Text.RegularExpressions (1)

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

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

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

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

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

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

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

System.Xaml (5)

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

48_resolvedTokensPendingProcessing = new Queue<NameFixupToken>();

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

99_buffer = new Queue<XamlNode>();

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

49_readNodesQueue = new Queue<XamlScannerNode>();

System\Xaml\Primitives\XamlNodeQueue.cs (1)

30_nodeQueue = new Queue<XamlNode>();

System\Xaml\XamlObjectReader.cs (1)

2483pendingNameScopes = new Queue<NameScopeMarkupInfo>();

173 references to Queue

Amg88xx (1)

Amg88xx.cs (1)

432var flagRegisters = new Queue<byte>();

Amg88xx.Tests (2)

I2cTestDevice.cs (2)

12public Queue<byte> DataToRead { get; } = new Queue<byte>(); 13public Queue<byte> DataWritten { get; } = new Queue<byte>();

Arduino (1)

FirmataDevice.cs (1)

54private Queue<byte> _dataQueue;

dotnet (2)

Installer\Windows\PipeStreamSetupLogger.cs (1)

22private readonly Queue<string> _messageQueue = new Queue<string>();

Telemetry\PersistenceChannel\FixedSizeQueue.cs (1)

15private readonly Queue<T> _queue = new Queue<T>();

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)

dotnet-watch (1)

HotReload\HotReloadProfileReader.cs (1)

17var queue = new Queue<ProjectGraphNode>(projectGraph.EntryPointNodes);

Iot.Device.Bindings (5)

Amg88xx.cs (1)

432var flagRegisters = new Queue<byte>();

FirmataDevice.cs (1)

54private Queue<byte> _dataQueue;

NmeaUdpServer.cs (1)

165private readonly Queue<byte> _data;

SentenceCache.cs (2)

23private Queue<RoutePart> _lastRouteSentences; 25private Queue<SatellitesInView> _lastSatelliteInfos;

Microsoft.AspNetCore.Components (2)

Rendering\RenderBatchBuilder.cs (2)

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

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)

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

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

Internal\Http2\Http2FrameWriter.cs (1)

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

Microsoft.AspNetCore.TestHost (1)

TestWebSocket.cs (1)

251private readonly Queue<Message> _messageQueue;

Microsoft.Build (6)

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

75private readonly Queue<PendingUnsubmittedBuildRequests> _unsubmittedRequests;

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

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

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

114private Queue<TaskCompletionSource<int>> _pendingRequestCoresCallbacks; 2578Queue<SchedulableRequest> blockingRequests = new Queue<SchedulableRequest>();

Graph\ProjectGraph.cs (2)

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

Microsoft.Build.Engine (14)

Collections\DualQueue.cs (8)

80Queue<T> readingQueue = backingQueueB; 202Queue<T> readingQueue = GetReadingQueue(); 236private Queue<T> GetReadingQueue() 238Queue<T> readingQueue = backingQueueB; 256Queue<T> postingQueue = queue; 302private Queue<T> queue; 307private Queue<T> backingQueueA; 312private Queue<T> backingQueueB;

Engine\Node.cs (1)

635private Queue<BuildRequest> buildRequests;

Engine\TaskWorkerThread.cs (4)

71Queue<TaskWorkerThread> workerThreadQueue, 73Queue<TaskExecutionState> workItemQueue, 600private Queue<TaskWorkerThread> workerThreadQueue; // Queue of idle worker thread ready to be activated 602private Queue<TaskExecutionState> workItemQueue; // Queue of workitems that need to be executed

LocalProvider\LocalNodeProvider.cs (1)

989private Queue<int> nodesToLaunch;

Microsoft.Cci.Extensions (2)

Extensions\CSharp\CSharpCciExtensions.cs (2)

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

Microsoft.DotNet.ApiCompatibility (1)

Abstractions\Mappers\AssemblyMapper.cs (1)

64Queue<INamespaceSymbol> queue = new();

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)

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

Microsoft.DotNet.PackageValidation (1)

Validators\CompatibleFrameworkInPackageValidator.cs (1)

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

Microsoft.Extensions.Logging.Console (1)

ConsoleLoggerProcessor.cs (1)

17private readonly Queue<LogMessageEntry> _messageQueue;

Microsoft.ML.Core (2)

Data\Repository.cs (1)

287private 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.StandardTrainers (1)

Optimizer\OptimizationMonitor.cs (1)

198private readonly Queue<float> _pastValues;

Microsoft.ML.Transforms (1)

Expression\Lexer.cs (1)

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

Microsoft.TemplateEngine.Cli (1)

Commands\Example.cs (1)

163Queue<Command> probes = new Queue<Command>();

MSBuild (1)

OutOfProcTaskHostNode.cs (1)

84private Queue<INodePacket> _receivedPackets;

MSBuildTaskHost (1)

OutOfProcTaskHostNode.cs (1)

84private Queue<INodePacket> _receivedPackets;

mscorlib (1)

mscorlib.forwards.cs (1)

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

netstandard (1)

artifacts\obj\netstandard\Debug\net7.0-linux\netstandard.Forwards.cs (1)

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

Nmea0183 (3)

NmeaUdpServer.cs (1)

165private readonly Queue<byte> _data;

SentenceCache.cs (2)

23private Queue<RoutePart> _lastRouteSentences; 25private Queue<SatellitesInView> _lastSatelliteInfos;

PresentationCore (4)

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

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

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

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

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

918private Queue<WeakReference> _eventQueue;

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

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

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

System (1)

artifacts\obj\System\Debug\net7.0-linux\System.Forwards.cs (1)

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

System.CodeDom (1)

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

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

System.Collections (3)

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

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

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

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

161Queue<TSource> queue = new();

System\Linq\Take.cs (1)

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

57private readonly Queue<Pair<TKey, TOutput>>[] _buffers; 130_buffers = new Queue<Pair<TKey, TOutput>>[partitionCount]; 237private readonly Queue<Pair<TKey, TOutput>>?[] _privateBuffer; 254_privateBuffer = new Queue<Pair<TKey, TOutput>>[partitionCount]; 390Queue<Pair<TKey, TOutput>> buffer = _mergeHelper._buffers[producer]; 460var privateChunk = _privateBuffer[producer];

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

31private readonly Queue<Pair<TKey, TOutput>>[] _buffers; // The buffer for the results 60Queue<Pair<TKey, TOutput>>[] buffers, 148Queue<Pair<TKey, TOutput>>[] buffers, object[] bufferLocks,

System.Private.CoreLib (5)

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

422private readonly Queue<T> _q; 427internal 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;

System.Private.DataContractSerialization (3)

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

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

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

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

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

46private Queue<IDataNode>? _deserializedDataNodes;

System.Private.ServiceModel (19)

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

22private Queue<IQueueReader> _readerQueue;

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

1075private 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.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; 1578public void AddToFreeLocals(Dictionary<(Type, string), Queue<LocalBuilder>> freeLocals) 1583Queue<LocalBuilder>? freeLocalQueue;

System.Runtime.Serialization.Formatters (1)

System\Runtime\Serialization\Formatters\Binary\BinaryObjectWriter.cs (1)

14private Queue<object>? _objectQueue;

System.Text.Json (12)

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

379var next = new Queue<T>();

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

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

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

10where TCollection : Queue<TElement>

System\Text\Json\Serialization\JsonSerializer.Read.Stream.cs (6)

411private static JsonTypeInfo<Queue<TValue>> CreateQueueTypeInfo<TValue>(JsonTypeInfo jsonTypeInfo) 413JsonTypeInfo<Queue<TValue>> queueTypeInfo = JsonMetadataServices.CreateQueueInfo<Queue<TValue>, TValue>( 428JsonTypeInfo<Queue<TValue>> queueTypeInfo, 444ContinueDeserialize<Queue<TValue>>( 450if (readStack.Current.ReturnValue is Queue<TValue> queue)

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

259/// Creates serialization metadata for types assignable to <see cref="Queue{T}"/>. 270where TCollection : Queue<TElement> 295/// Creates serialization metadata for types assignable to <see cref="Queue{T}"/>.

System.Text.Json.SourceGeneration (2)

JsonSourceGenerator.Parser.cs (1)

207_queueOfTType = _metadataLoadContext.Resolve(typeof(Queue<>));

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

379var next = new Queue<T>();

System.Text.RegularExpressions (4)

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

25Queue<MatchingState<TSet>> toExplore = new(); 68static (int nfaId, (SymbolicRegexMatcher<TSet> Matcher, HashSet<MatchingState<TSet>> Seen, Queue<MatchingState<TSet>> ToExplore) args) => 95static void EnqueueAll(MatchingState<TSet>[] states, HashSet<MatchingState<TSet>> seen, Queue<MatchingState<TSet>> toExplore) 103static 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)

331private Queue<ThreadMethodEntry>? _threadCallbackList;

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

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

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

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

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)

30Queue<NameFixupToken> _resolvedTokensPendingProcessing;

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

21Queue<XamlNode> _buffer;

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

36Queue<XamlScannerNode> _readNodesQueue;

System\Xaml\Primitives\XamlNodeQueue.cs (1)

17Queue<XamlNode> _nodeQueue;

System\Xaml\XamlObjectReader.cs (2)

2472Queue<NameScopeMarkupInfo> pendingNameScopes; 2520public Queue<NameScopeMarkupInfo> PendingNameScopes