40 references to ProducerConsumer
Microsoft.CodeAnalysis.CSharp.Features (1)
CodeRefactorings\EnableNullable\EnableNullableCodeRefactoringProvider.cs (1)
72var updatedDocumentRoots = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
Microsoft.CodeAnalysis.CSharp.Workspaces (1)
src\Workspaces\SharedUtilitiesAndExtensions\Workspace\CSharp\Editing\CSharpImportAdder.cs (1)
134await ProducerConsumer<INamespaceSymbol>.RunParallelAsync(
Microsoft.CodeAnalysis.ExternalAccess.Copilot (1)
Internal\Completion\CSharpContextProviderService.cs (1)
25=> ProducerConsumer<IContextItem>.RunParallelStreamAsync(
Microsoft.CodeAnalysis.Features (25)
AddImport\AbstractAddImportFeatureService.cs (2)
235await ProducerConsumer<ImmutableArray<SymbolReference>>.RunParallelAsync( 286await ProducerConsumer<ImmutableArray<SymbolReference>>.RunParallelAsync(
ChangeSignature\AbstractChangeSignatureService.cs (1)
418var changedDocuments = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
CodeFixes\Suppression\AbstractSuppressionBatchFixAllProvider.cs (1)
95return await ProducerConsumer<(Diagnostic diagnostic, CodeAction action)>.RunParallelAsync(
CodeRefactorings\AddMissingImports\AbstractAddMissingImportsFeatureService.cs (1)
96var changes = ProducerConsumer<TextChange>.RunParallelStreamAsync(
CodeRefactorings\CodeRefactoringService.cs (2)
133return await ProducerConsumer<VoidResult>.RunParallelAsync( 193var pairs = await ProducerConsumer<(CodeRefactoringProvider provider, CodeRefactoring codeRefactoring)>.RunParallelAsync(
CodeRefactorings\SyncNamespace\AbstractChangeNamespaceService.cs (2)
487var fixedDocuments = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync( 819var changedDocuments = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
Completion\CompletionService_GetCompletions.cs (1)
238return await ProducerConsumer<CompletionContext>.RunParallelAsync(
Completion\Providers\AbstractSymbolCompletionProvider.cs (1)
415return await ProducerConsumer<(DocumentId documentId, TSyntaxContext syntaxContext, ImmutableArray<SymbolAndSelectionInfo> symbols)>.RunParallelAsync(
Completion\Providers\ImportCompletionProvider\ExtensionMethodImportCompletionHelper.SymbolComputer.cs (2)
86var peReferenceMethodSymbolsTask = ProducerConsumer<IMethodSymbol?>.RunParallelAsync( 93var projectMethodSymbolsTask = ProducerConsumer<IMethodSymbol?>.RunParallelAsync(
Copilot\ICopilotChangeAnalysisService.cs (4)
168return ProducerConsumer<CopilotDiagnosticAnalysis>.RunParallelAsync( 209return ProducerConsumer<DiagnosticData>.RunParallelAsync( 252await ProducerConsumer<(CodeFixCollection collection, bool success, TimeSpan elapsedTime)>.RunParallelAsync( 340return ProducerConsumer<CodeFixCollection>.RunParallelAsync(
FindUsages\AbstractFindUsagesService.ProgressAdapter.cs (1)
118await ProducerConsumer<SourceReferenceItem>.RunParallelAsync(
IntroduceParameter\AbstractIntroduceParameterCodeRefactoringProvider.cs (1)
249var changedRoots = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
NavigateTo\AbstractNavigateToSearchService.CachedDocumentSearch.cs (1)
124await ProducerConsumer<RoslynNavigateToItem>.RunParallelAsync(
NavigateTo\AbstractNavigateToSearchService.GeneratedDocumentSearch.cs (1)
71await ProducerConsumer<RoslynNavigateToItem>.RunParallelAsync(
NavigateTo\AbstractNavigateToSearchService.NormalSearch.cs (2)
72=> ProducerConsumer<RoslynNavigateToItem>.RunParallelAsync( 206await ProducerConsumer<RoslynNavigateToItem>.RunParallelAsync(
RelatedDocuments\AbstractRelatedDocumentsService.cs (1)
95await ProducerConsumer<DocumentId>.RunParallelAsync(
src\Analyzers\Core\CodeFixes\UseAutoProperty\UseAutoPropertyFixAllProvider.cs (1)
62var documentsIdsAndNewRoots = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
Microsoft.CodeAnalysis.LanguageServer (1)
HostWorkspace\LanguageServerProjectLoader.cs (1)
166var projectsThatNeedRestore = await ProducerConsumer<string>.RunParallelAsync(
Microsoft.CodeAnalysis.Remote.ServiceHub (1)
Services\ConvertTupleToStructCodeRefactoringProvider\RemoteConvertTupleToStructCodeRefactoringService.cs (1)
78var changedDocuments = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
Microsoft.CodeAnalysis.Remote.Workspaces (1)
RemoteHostAssetWriter.cs (1)
72=> ProducerConsumer<ChecksumAndAsset>.RunAsync(
Microsoft.CodeAnalysis.Workspaces (8)
CodeActions\CodeAction_Cleanup.cs (1)
187var changedRoots = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(
CodeFixes\FixAllOccurrences\FixAllContext.DiagnosticProvider.cs (1)
85return await ProducerConsumer<(Project project, ImmutableArray<Diagnostic> diagnostics)>.RunParallelAsync(
CodeFixesAndRefactorings\DocumentBasedFixAllProviderHelpers.cs (1)
67var changedRootsAndTexts = await ProducerConsumer<(DocumentId documentId, (SyntaxNode? node, SourceText? text))>.RunParallelAsync(
Diagnostics\Extensions.cs (1)
404return await ProducerConsumer<Diagnostic>.RunParallelAsync(
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (1)
69await ProducerConsumer<Reference>.RunAsync(
FindSymbols\FindReferences\FindReferencesSearchEngine_FindReferencesInDocuments.cs (1)
135await ProducerConsumer<FinderLocation>.RunAsync(
src\Workspaces\SharedUtilitiesAndExtensions\Workspace\Core\CodeFixes\FixAllContextHelper.cs (1)
80allDiagnostics = await ProducerConsumer<ImmutableArray<Diagnostic>>.RunParallelAsync(
Workspace\Solution\SolutionCompilationState.TranslationAction_Actions.cs (1)
182var documentsAndTrees = await ProducerConsumer<(DocumentState document, SyntaxTree tree)>.RunParallelAsync(
Microsoft.VisualStudio.LanguageServices (1)
CodeCleanup\AbstractCodeCleanUpFixer.cs (1)
204var changedRoots = await ProducerConsumer<(DocumentId documentId, SyntaxNode newRoot)>.RunParallelAsync(