ConcurrentBag

42 instantiations of ConcurrentBag

AnalyzerRunner (1)

Program.cs (1)

190var sums = new ConcurrentBag<Statistic>();

aspire (1)

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

202var failedSockets = new ConcurrentBag<string>();

Aspire.Hosting (1)

ApplicationModel\EndpointAnnotation.cs (1)

283private readonly ConcurrentBag<NetworkEndpointSnapshot> _snapshots = new();

Aspire.Hosting.Integration.Analyzers (1)

AspireExportAnalyzer.cs (1)

217var bag = exportsByKey.GetOrAdd(key, _ => new ConcurrentBag<(IMethodSymbol, Location)>());

Aspire.TestUtilities (1)

TestLoggerFactory.cs (1)

13public ConcurrentBag<string> Categories { get; } = new();

InMemory.FunctionalTests (1)

RequestTests.cs (1)

599var usedIds = new ConcurrentBag<string>();

Microsoft.AspNetCore.Analyzers.Test (6)

MinimalStartupTest.cs (3)

18Analyses = new ConcurrentBag<object>(); 19ConfigureServicesMethods = new ConcurrentBag<IMethodSymbol>(); 20ConfigureMethods = new ConcurrentBag<IMethodSymbol>();

StartupAnalyzerTest.cs (3)

16Analyses = new ConcurrentBag<object>(); 17ConfigureServicesMethods = new ConcurrentBag<IMethodSymbol>(); 18ConfigureMethods = new ConcurrentBag<IMethodSymbol>();

Microsoft.AspNetCore.Components.Endpoints (1)

FormMapping\Converters\CollectionAdapters\ConcurrentBagBufferAdapter.cs (1)

10public static ConcurrentBag<TElement> CreateBuffer() => new();

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

Binding\FormDataMapperTests.cs (1)

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

Microsoft.AspNetCore.Http.Extensions (1)

src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\ConcurrentBagBufferAdapter.cs (1)

10public static ConcurrentBag<TElement> CreateBuffer() => new();

Microsoft.Build (5)

BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)

91ConcurrentBag<NodeInfo> nodes = new();

BuildCheck\Infrastructure\BuildCheckManagerProvider.cs (2)

75_checkRegistry = new ConcurrentBag<CheckFactoryContext>(); 395var tempColl = new ConcurrentBag<CheckFactoryContext>();

BuildCheck\Infrastructure\EditorConfig\EditorConfigParser.cs (2)

17private static ConcurrentBag<string> editorConfigFilePaths = new ConcurrentBag<string>(); 38editorConfigFilePaths = new ConcurrentBag<string>();

Microsoft.Build.Engine.UnitTests (1)

ProjectCache\ProjectCacheTests.cs (1)

1387var completedCacheRequests = new ConcurrentBag<int>();

Microsoft.Build.TaskAuthoring.Analyzer (6)

TransitiveCallChainAnalyzer.cs (6)

153callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(calleeKey); 160callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(property.GetMethod.OriginalDefinition); 165callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(property.SetMethod.OriginalDefinition); 181directViolations.GetOrAdd(callerKey, _ => new ConcurrentBag<ViolationInfo>()).Add(violation); 196directViolations.GetOrAdd(callerKey, _ => new ConcurrentBag<ViolationInfo>()).Add(violation); 212directViolations.GetOrAdd(callerKey, _ => new ConcurrentBag<ViolationInfo>()).Add(violation);

Microsoft.CodeAnalysis.Analyzers (1)

MetaAnalyzers\DiagnosticAnalyzerAPIUsageAnalyzer.cs (1)

95var diagnosticAnalyzerTypes = new ConcurrentBag<INamedTypeSymbol>();

Microsoft.CodeAnalysis.Features (1)

CodeFixes\Suppression\AbstractSuppressionBatchFixAllProvider.cs (1)

146var bag = new ConcurrentBag<(Diagnostic diagnostic, CodeAction action)>();

Microsoft.CodeAnalysis.Test.Utilities (2)

Diagnostics\CommonDiagnosticAnalyzers.cs (1)

1978var diagnostics = new ConcurrentBag<Diagnostic>();

TempFiles\TempRoot.cs (1)

16private readonly ConcurrentBag<IDisposable> _temps = new ConcurrentBag<IDisposable>();

Microsoft.DotNet.Baselines.Tasks (1)

PRCreator.cs (1)

81ConcurrentBag<NewTreeItem> treeItems = new();

Microsoft.DotNet.Deployment.Tasks.Links (2)

src\AkaMSLinksManager.cs (2)

187ConcurrentBag<AkaMSLink> linksToCreate = new ConcurrentBag<AkaMSLink>(); 188ConcurrentBag<AkaMSLink> linksToUpdate = new ConcurrentBag<AkaMSLink>();

Microsoft.DotNet.SourceBuild.Tasks (1)

src\UsageReport\WritePackageUsageData.cs (1)

176var usages = new ConcurrentBag<Usage>();

Microsoft.Maui.Resizetizer (1)

ResizetizeImages.cs (1)

49 var resizedImages = new ConcurrentBag<ResizedImageInfo>();

Microsoft.ML.Core (1)

Utilities\ObjectPool.cs (1)

46_pool = new ConcurrentBag<T>();

Microsoft.ML.Data (1)

DataView\CacheDataView.cs (1)

99_cacheFillerThreads = new ConcurrentBag<Task>();

Microsoft.ML.TensorFlow (1)

TensorflowTransform.cs (1)

638_runners = new ConcurrentBag<Runner>();

Microsoft.ML.Transforms (1)

Text\WordEmbeddingsExtractor.cs (1)

679var parsedData = new ConcurrentBag<(string key, float[] values, long lineNumber)>();

Microsoft.ML.Vision (1)

DnnRetrainTransform.cs (1)

839_runners = new ConcurrentBag<Runner>();

System.Reflection.MetadataLoadContext (1)

System\Reflection\MetadataLoadContext.Disposing.cs (1)

11private ConcurrentBag<IDisposable> _disposables = new ConcurrentBag<IDisposable>();

136 references to ConcurrentBag

AnalyzerRunner (1)

Program.cs (1)

190var sums = new ConcurrentBag<Statistic>();

aspire (2)

Backchannel\AuxiliaryBackchannelMonitor.cs (2)

202var failedSockets = new ConcurrentBag<string>(); 280private async Task TryConnectToSocketAsync(string socketPath, ConcurrentBag<string> failedSockets, CancellationToken cancellationToken)

Aspire.Hosting (1)

ApplicationModel\EndpointAnnotation.cs (1)

283private readonly ConcurrentBag<NetworkEndpointSnapshot> _snapshots = new();

Aspire.Hosting.Integration.Analyzers (4)

AspireExportAnalyzer.cs (4)

75var exportsByKey = new ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>>(); 123ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>> exportsByKey) 217var bag = exportsByKey.GetOrAdd(key, _ => new ConcurrentBag<(IMethodSymbol, Location)>()); 762ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>> exportsByKey)

Aspire.Hosting.Tests (8)

MockImageBuilder.cs (3)

19public ConcurrentBag<IResource> BuildImageResources { get; } = []; 20public ConcurrentBag<ContainerImageBuildOptions?> BuildImageOptions { get; } = []; 21public ConcurrentBag<IResource> PushImageCalls { get; } = [];

Publishing\FakeContainerRuntime.cs (5)

24public ConcurrentBag<(string localImageName, string targetImageName)> TagImageCalls { get; } = []; 25public ConcurrentBag<string> RemoveImageCalls { get; } = []; 26public ConcurrentBag<IResource> PushImageCalls { get; } = []; 27public ConcurrentBag<(string contextPath, string dockerfilePath, ContainerImageBuildOptions? options)> BuildImageCalls { get; } = []; 28public ConcurrentBag<(string registryServer, string username, string password)> LoginToRegistryCalls { get; } = [];

Aspire.TestUtilities (1)

TestLoggerFactory.cs (1)

13public ConcurrentBag<string> Categories { get; } = new();

InMemory.FunctionalTests (1)

RequestTests.cs (1)

599var usedIds = new ConcurrentBag<string>();

Microsoft.AspNetCore.Analyzers.Test (6)

MinimalStartupTest.cs (3)

30internal ConcurrentBag<object> Analyses { get; } 32internal ConcurrentBag<IMethodSymbol> ConfigureServicesMethods { get; } 34internal ConcurrentBag<IMethodSymbol> ConfigureMethods { get; }

StartupAnalyzerTest.cs (3)

28internal ConcurrentBag<object> Analyses { get; } 30internal ConcurrentBag<IMethodSymbol> ConfigureServicesMethods { get; } 32internal ConcurrentBag<IMethodSymbol> ConfigureMethods { get; }

Microsoft.AspNetCore.Components.Endpoints (11)

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

8internal sealed class ConcurrentBagBufferAdapter<TElement> : ICollectionBufferAdapter<ConcurrentBag<TElement>, ConcurrentBag<TElement>, TElement> 10public static ConcurrentBag<TElement> CreateBuffer() => new(); 12public static ConcurrentBag<TElement> Add(ref ConcurrentBag<TElement> buffer, TElement element) 18public static ConcurrentBag<TElement> ToResult(ConcurrentBag<TElement> buffer) => buffer;

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

51var _ when type == (typeof(ConcurrentBag<TElement>)) => true, 141var _ when type.IsAssignableTo(typeof(ConcurrentBag<TElement>)) => 142new CollectionConverter<ConcurrentBag<TElement>, ConcurrentBagBufferAdapter<TElement>, ConcurrentBag<TElement>, TElement>(elementTypeConverter),

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

Binding\FormDataMapperTests.cs (3)

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

Microsoft.AspNetCore.Http.Extensions (11)

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

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

Microsoft.Build (5)

BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)

91ConcurrentBag<NodeInfo> nodes = new();

BuildCheck\Infrastructure\BuildCheckManagerProvider.cs (3)

68private readonly ConcurrentBag<CheckFactoryContext> _checkRegistry; 395var tempColl = new ConcurrentBag<CheckFactoryContext>(); 508private readonly ConcurrentBag<BuildCheckRuleTelemetryData> _ruleTelemetryData = [];

BuildCheck\Infrastructure\EditorConfig\EditorConfigParser.cs (1)

17private static ConcurrentBag<string> editorConfigFilePaths = new ConcurrentBag<string>();

Microsoft.Build.Engine.UnitTests (1)

ProjectCache\ProjectCacheTests.cs (1)

1387var completedCacheRequests = new ConcurrentBag<int>();

Microsoft.Build.TaskAuthoring.Analyzer (9)

TransitiveCallChainAnalyzer.cs (9)

69var callGraph = new ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>>(SymbolEqualityComparer.Default); 70var directViolations = new ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>>(SymbolEqualityComparer.Default); 97ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>> callGraph, 98ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>> directViolations, 223ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>> callGraph, 224ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>> directViolations, 279if (callGraph.TryGetValue(methodKey, out var directCallees)) 301if (directViolations.TryGetValue(current, out var violations)) 315bool hasSourceEdges = callGraph.TryGetValue(current, out var callees);

Microsoft.CodeAnalysis.Analyzers (11)

MetaAnalyzers\DiagnosticAnalyzerAPIUsageAnalyzer.cs (1)

95var diagnosticAnalyzerTypes = new ConcurrentBag<INamedTypeSymbol>();

MetaAnalyzers\DiagnosticDescriptorCreationAnalyzer.cs (10)

250var idToAnalyzerMap = new ConcurrentDictionary<string, ConcurrentDictionary<string, ConcurrentBag<Location>>>(); 476var locations = analyzerToDescriptorLocationsMap[analyzerName]; 1196ConcurrentDictionary<string, ConcurrentDictionary<string, ConcurrentBag<Location>>> idToAnalyzerMap) 1217ConcurrentBag<Location> AddLocationFactory(string analyzerName) 1220ConcurrentBag<Location> UpdateLocationsFactory(string analyzerName, ConcurrentBag<Location> bag) 1226ConcurrentDictionary<string, ConcurrentBag<Location>> AddNamedTypeFactory(string r) 1228var dict = new ConcurrentDictionary<string, ConcurrentBag<Location>>(); 1236ConcurrentDictionary<string, ConcurrentBag<Location>> UpdateNamedTypeFactory(string r, ConcurrentDictionary<string, ConcurrentBag<Location>> existingValue)

Microsoft.CodeAnalysis.CSharp.EditorFeatures.UnitTests (1)

NavigateTo\NavigateToSearcherTests.cs (1)

481public readonly ConcurrentBag<INavigateToSearchResult> Results = [];

Microsoft.CodeAnalysis.Features (8)

CodeFixes\Suppression\AbstractSuppressionBatchFixAllProvider.cs (7)

146var bag = new ConcurrentBag<(Diagnostic diagnostic, CodeAction action)>(); 201ConcurrentBag<(Diagnostic diagnostic, CodeAction action)> fixes, 248private static async Task<IReadOnlyDictionary<DocumentId, ConcurrentBag<(CodeAction, Document)>>> GetDocumentIdToChangedDocumentsAsync( 254var documentIdToChangedDocuments = new ConcurrentDictionary<DocumentId, ConcurrentBag<(CodeAction, Document)>>(); 272IReadOnlyDictionary<DocumentId, ConcurrentBag<(CodeAction, Document)>> documentIdToChangedDocuments, 340private static readonly Func<DocumentId, ConcurrentBag<(CodeAction, Document)>> s_getValue = 345ConcurrentDictionary<DocumentId, ConcurrentBag<(CodeAction, Document)>> documentIdToChangedDocuments,

CodeFixes\Suppression\AbstractSuppressionCodeFixProvider.RemoveSuppressionCodeAction.BatchFixer.cs (1)

86ConcurrentBag<(Diagnostic diagnostic, CodeAction action)> bag,

Microsoft.CodeAnalysis.LanguageServer (1)

Testing\TestDiscoverer.DiscoveryHandler.cs (1)

24private readonly ConcurrentBag<TestCase> _testCases = [];

Microsoft.CodeAnalysis.Test.Utilities (2)

Diagnostics\CommonDiagnosticAnalyzers.cs (1)

1978var diagnostics = new ConcurrentBag<Diagnostic>();

TempFiles\TempRoot.cs (1)

16private readonly ConcurrentBag<IDisposable> _temps = new ConcurrentBag<IDisposable>();

Microsoft.DotNet.Baselines.Tasks (2)

PRCreator.cs (2)

81ConcurrentBag<NewTreeItem> treeItems = new(); 96ConcurrentBag<NewTreeItem> treeItems,

Microsoft.DotNet.Deployment.Tasks.Links (2)

src\AkaMSLinksManager.cs (2)

187ConcurrentBag<AkaMSLink> linksToCreate = new ConcurrentBag<AkaMSLink>(); 188ConcurrentBag<AkaMSLink> linksToUpdate = new ConcurrentBag<AkaMSLink>();

Microsoft.DotNet.SourceBuild.Tasks (1)

src\UsageReport\WritePackageUsageData.cs (1)

176var usages = new ConcurrentBag<Usage>();

Microsoft.Maui.Resizetizer (4)

ResizetizeImages.cs (4)

49 var resizedImages = new ConcurrentBag<ResizedImageInfo>(); 164 void ProcessAppIcon(ResizeImageInfo img, ConcurrentBag<ResizedImageInfo> resizedImages) 236 void ProcessImageResize(ResizeImageInfo img, DpiPath[] dpis, ConcurrentBag<ResizedImageInfo> resizedImages) 251 void ProcessImageCopy(ResizeImageInfo img, DpiPath originalScaleDpi, ConcurrentBag<ResizedImageInfo> resizedImages)

Microsoft.ML.Core (1)

Utilities\ObjectPool.cs (1)

38private readonly ConcurrentBag<T> _pool;

Microsoft.ML.Data (1)

DataView\CacheDataView.cs (1)

56private readonly ConcurrentBag<Task> _cacheFillerThreads;

Microsoft.ML.TensorFlow (1)

TensorflowTransform.cs (1)

540private readonly ConcurrentBag<Runner> _runners;

Microsoft.ML.Transforms (1)

Text\WordEmbeddingsExtractor.cs (1)

679var parsedData = new ConcurrentBag<(string key, float[] values, long lineNumber)>();

Microsoft.ML.Vision (1)

DnnRetrainTransform.cs (1)

763private readonly ConcurrentBag<Runner> _runners;

netstandard (1)

netstandard.cs (1)

94[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentBag<>))]

System (1)

src\libraries\shims\System\ref\System.cs (1)

133[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentBag<>))]

System.Collections.Concurrent (31)

System\Collections\Concurrent\ConcurrentBag.cs (31)

System.Reflection.MetadataLoadContext (2)

System\Reflection\MetadataLoadContext.Disposing.cs (2)

11private ConcurrentBag<IDisposable> _disposables = new ConcurrentBag<IDisposable>(); 34ConcurrentBag<IDisposable> disposables = _disposables;