AsyncQueue

40 instantiations of AsyncQueue

Microsoft.CodeAnalysis (7)

DiagnosticAnalyzer\AnalyzerDriver.cs (1)

844.WithEventQueue(new AsyncQueue<CompilationEvent>());

DiagnosticAnalyzer\CompilationWithAnalyzers.cs (4)

51private readonly ObjectPool<AsyncQueue<CompilationEvent>> _eventQueuePool = new ObjectPool<AsyncQueue<CompilationEvent>>(() => new AsyncQueue<CompilationEvent>()); 52private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 105.WithEventQueue(new AsyncQueue<CompilationEvent>()); 742compilation = _compilation.WithSemanticModelProvider(new CachingSemanticModelProvider()).WithEventQueue(new AsyncQueue<CompilationEvent>());

DiagnosticAnalyzer\DiagnosticQueue.cs (2)

44_queue = new AsyncQueue<Diagnostic>(); 49_queue = new AsyncQueue<Diagnostic>();

Microsoft.CodeAnalysis.CSharp.Emit2.UnitTests (9)

Diagnostics\CompilationEventTests.cs (5)

94var q = new AsyncQueue<CompilationEvent>(); 148var q = new AsyncQueue<CompilationEvent>(); 153q = new AsyncQueue<CompilationEvent>(); 163q = new AsyncQueue<CompilationEvent>(); 173q = new AsyncQueue<CompilationEvent>();

Diagnostics\GetDiagnosticsTests.cs (4)

167var eventQueue = new AsyncQueue<CompilationEvent>(); 216var eventQueue = new AsyncQueue<CompilationEvent>(); 254var eventQueue = new AsyncQueue<CompilationEvent>(); 313var compilation = CreateCompilationWithMscorlib45(CSharpTestSource.None).WithEventQueue(new AsyncQueue<CompilationEvent>());

Microsoft.CodeAnalysis.UnitTests (14)

AsyncQueueTests.cs (14)

26var queue = new AsyncQueue<int>(); 36var queue = new AsyncQueue<int>(); 44var queue = new AsyncQueue<int>(); 53var queue = new AsyncQueue<int>(); 65var queue = new AsyncQueue<int>(); 75var queue = new AsyncQueue<int>(); 96var queue = new AsyncQueue<int>(); 117var queue = new AsyncQueue<int>(); 144var queue = new AsyncQueue<int>(); 165var queue = new AsyncQueue<int>(); 177var queue = new AsyncQueue<int>(); 194var queue = new AsyncQueue<int>(); 206var queue = new AsyncQueue<int>(); 221var queue = new AsyncQueue<int>();

Microsoft.CodeAnalysis.VisualBasic.Semantic.UnitTests (9)

Diagnostics\CompilationEventTests.vb (6)

97Dim q = New AsyncQueue(Of CompilationEvent)() 163Dim q = New AsyncQueue(Of CompilationEvent)() 168q = New AsyncQueue(Of CompilationEvent)() 174q = New AsyncQueue(Of CompilationEvent)() 180q = New AsyncQueue(Of CompilationEvent)() 201Dim q = New AsyncQueue(Of CompilationEvent)()

Diagnostics\GetDiagnosticsTests.vb (3)

151Dim eventQueue = New AsyncQueue(Of CompilationEvent)() 206Dim eventQueue = New AsyncQueue(Of CompilationEvent)() 454Dim compilation = CreateCompilationWithMscorlib45(source:=Nothing).WithEventQueue(New AsyncQueue(Of CompilationEvent)())

VBCSCompiler (1)

NamedPipeClientConnectionHost.cs (1)

60_queue = new AsyncQueue<ListenResult>();

57 references to AsyncQueue

Microsoft.CodeAnalysis (23)

Compilation\Compilation.cs (3)

76AsyncQueue<CompilationEvent>? eventQueue) 293internal abstract Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue); 630internal AsyncQueue<CompilationEvent>? EventQueue { get; }

DiagnosticAnalyzer\AnalyzerDriver.cs (6)

26/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis. 334private AsyncQueue<CompilationEvent>? _lazyCompilationEventQueue; 339public AsyncQueue<CompilationEvent> CompilationEventQueue 626internal async Task AttachQueueAndProcessAllEventsAsync(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, CancellationToken cancellationToken) 658internal void AttachQueueAndStartProcessingEvents(AsyncQueue<CompilationEvent> eventQueue, AnalysisScope analysisScope, bool usingPrePopulatedEventQueue, CancellationToken cancellationToken) 2299/// It uses a <see cref="AsyncQueue{TElement}"/> of <see cref="CompilationEvent"/>s to drive its analysis.

DiagnosticAnalyzer\AsyncQueue.cs (1)

163/// Same operation as <see cref="AsyncQueue{TElement}.Complete"/> except it will not

DiagnosticAnalyzer\CompilationWithAnalyzers.cs (12)

51private readonly ObjectPool<AsyncQueue<CompilationEvent>> _eventQueuePool = new ObjectPool<AsyncQueue<CompilationEvent>>(() => new AsyncQueue<CompilationEvent>()); 52private static readonly AsyncQueue<CompilationEvent> s_EmptyEventQueue = new AsyncQueue<CompilationEvent>(); 306AsyncQueue<CompilationEvent> eventQueue = _eventQueuePool.Allocate(); 761ObjectPool<AsyncQueue<CompilationEvent>> eventQueuePool, 768AsyncQueue<CompilationEvent>? eventQueue = null; 1001var eventQueue = compilation.EventQueue!; 1125private static AsyncQueue<CompilationEvent> CreateEventsQueue(ImmutableArray<CompilationEvent> compilationEvents, ObjectPool<AsyncQueue<CompilationEvent>> eventQueuePool) 1132var eventQueue = eventQueuePool.Allocate(); 1144private static void FreeEventQueue(AsyncQueue<CompilationEvent>? eventQueue, ObjectPool<AsyncQueue<CompilationEvent>> eventQueuePool)

DiagnosticAnalyzer\DiagnosticQueue.cs (1)

40private readonly AsyncQueue<Diagnostic> _queue;

Microsoft.CodeAnalysis.CSharp (3)

Compilation\CSharpCompilation.cs (3)

438AsyncQueue<CompilationEvent>? eventQueue = null) 456AsyncQueue<CompilationEvent>? eventQueue = null) 726internal override Compilation WithEventQueue(AsyncQueue<CompilationEvent>? eventQueue)

Microsoft.CodeAnalysis.CSharp.Emit2.UnitTests (9)

Diagnostics\CompilationEventTests.cs (4)

18internal static void VerifyEvents(AsyncQueue<CompilationEvent> queue, params string[] expectedEvents) 94var q = new AsyncQueue<CompilationEvent>(); 111private static void VerifyEvents(AsyncQueue<CompilationEvent> q) 148var q = new AsyncQueue<CompilationEvent>();

Diagnostics\GetDiagnosticsTests.cs (5)

167var eventQueue = new AsyncQueue<CompilationEvent>(); 216var eventQueue = new AsyncQueue<CompilationEvent>(); 254var eventQueue = new AsyncQueue<CompilationEvent>(); 261private static bool DequeueCompilationEvents(AsyncQueue<CompilationEvent> eventQueue, out bool compilationStartedFired, out HashSet<string> declaredSymbolNames, out HashSet<string> completedCompilationUnits) 730var eventQueue = compilationWithAnalyzers.Compilation.EventQueue;

Microsoft.CodeAnalysis.UnitTests (15)

AsyncQueueTests.cs (15)

26var queue = new AsyncQueue<int>(); 36var queue = new AsyncQueue<int>(); 44var queue = new AsyncQueue<int>(); 53var queue = new AsyncQueue<int>(); 65var queue = new AsyncQueue<int>(); 75var queue = new AsyncQueue<int>(); 96var queue = new AsyncQueue<int>(); 117var queue = new AsyncQueue<int>(); 144var queue = new AsyncQueue<int>(); 165var queue = new AsyncQueue<int>(); 177var queue = new AsyncQueue<int>(); 194var queue = new AsyncQueue<int>(); 206var queue = new AsyncQueue<int>(); 216/// after the <see cref="AsyncQueue{TElement}"/> is completed. 221var queue = new AsyncQueue<int>();

Microsoft.CodeAnalysis.VisualBasic (2)

Compilation\VisualBasicCompilation.vb (2)

431Optional eventQueue As AsyncQueue(Of CompilationEvent) = Nothing 735Friend Overrides Function WithEventQueue(eventQueue As AsyncQueue(Of CompilationEvent)) As Compilation

Microsoft.CodeAnalysis.VisualBasic.Semantic.UnitTests (3)

Diagnostics\CompilationEventTests.vb (2)

19Friend Shared Sub VerifyEvents(queue As AsyncQueue(Of CompilationEvent), ParamArray expectedEvents As String()) 102Private Shared Sub VerifyEvents(q As AsyncQueue(Of CompilationEvent))

Diagnostics\GetDiagnosticsTests.vb (1)

414Private Shared Function DequeueCompilationEvents(eventQueue As AsyncQueue(Of CompilationEvent), ByRef compilationStartedFired As Boolean, ByRef declaredSymbolNames As HashSet(Of String), ByRef completedCompilationUnits As HashSet(Of String)) As Boolean

VBCSCompiler (2)

NamedPipeClientConnectionHost.cs (2)

35private AsyncQueue<ListenResult>? _queue; 170AsyncQueue<ListenResult> queue,