ConcurrentBag

41 references to 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.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>();