57 instantiations of ConcurrentBag
aspire (2)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
396var failedSockets = new ConcurrentBag<string>();
Documentation\ApiDocs\ApiDocsIndexService.cs (1)
633var loadedContainers = new ConcurrentBag<LoadedMemberContainer>();
Aspire.Cli.Tests (8)
Acquisition\WingetRegistryProbeTests.cs (1)
67var errors = new ConcurrentBag<Exception>();
Backchannel\AuxiliaryBackchannelMonitorTests.cs (1)
465socket, new ConcurrentBag<string>(), prune, CancellationToken.None), time).DefaultTimeout();
Commands\AddCommandTests.cs (1)
2120var searchSources = new ConcurrentBag<string[]>();
Commands\LsCommandTests.cs (1)
760var startedActivities = new ConcurrentBag<Activity>();
Git\GitRepositoryTests.cs (1)
118var startedActivities = new ConcurrentBag<Activity>();
Projects\GuestRuntimeTests.cs (2)
258var stoppedActivities = new ConcurrentBag<Activity>(); 961var stoppedActivities = new ConcurrentBag<Activity>();
Utils\DcpConnectionHealthCheckTests.cs (1)
174var seenUseDeveloperCertificateValues = new ConcurrentBag<bool>();
Aspire.Hosting (1)
ApplicationModel\EndpointAnnotation.cs (1)
407private readonly ConcurrentBag<NetworkEndpointSnapshot> _snapshots = new();
Aspire.Hosting.Integration.Analyzers (1)
AspireExportAnalyzer.cs (1)
417var bag = exportsByKey.GetOrAdd(key, _ => new ConcurrentBag<(IMethodSymbol, Location)>());
Aspire.Hosting.Tests (4)
Dcp\DcpExecutorTests.cs (1)
9751var failedResources = new ConcurrentBag<string>();
Dcp\DcpHostNotificationTests.cs (1)
455var activities = new ConcurrentBag<Activity>();
DistributedApplicationTests.cs (2)
136var activities = new ConcurrentBag<Activity>(); 168var activities = new ConcurrentBag<Activity>();
Aspire.Playground.Tests (2)
BlazorWasmHostingTests.cs (2)
61var otlpRequests = new ConcurrentBag<(string Url, int StatusCode)>(); 141var otlpRequests = new ConcurrentBag<(string Url, int StatusCode)>();
Aspire.TestUtilities (1)
TestLoggerFactory.cs (1)
13public ConcurrentBag<string> Categories { get; } = new();
ILCompiler.ReadyToRun (3)
Compiler\DependencyAnalysis\ReadyToRun\ManifestMetadataTableNode.cs (1)
70private ConcurrentBag<EcmaModule> _modulesWhichMustBeIndexable = new ConcurrentBag<EcmaModule>();
Compiler\DependencyAnalysis\ReadyToRun\TypeValidationChecker.cs (1)
20private ConcurrentBag<(TypeDesc type, string reason)> _typeLoadValidationErrors = new ConcurrentBag<(TypeDesc type, string reason)>();
Compiler\DependencyAnalysis\ReadyToRunCodegenNodeFactory.cs (1)
629private readonly ConcurrentBag<StringDiscoverableAssemblyStubNode> _stringDiscoverableStubs = new ConcurrentBag<StringDiscoverableAssemblyStubNode>();
Microsoft.AspNetCore.Components.Endpoints (1)
FormMapping\Converters\CollectionAdapters\ConcurrentBagBufferAdapter.cs (1)
10public static ConcurrentBag<TElement> CreateBuffer() => new();
Microsoft.AspNetCore.Http.Extensions (1)
src\aspnetcore\src\Components\Endpoints\src\FormMapping\Converters\CollectionAdapters\ConcurrentBagBufferAdapter.cs (1)
10public static ConcurrentBag<TElement> CreateBuffer() => new();
Microsoft.Build (8)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
90ConcurrentBag<NodeInfo> nodes = new();
BuildCheck\Infrastructure\BuildCheckManagerProvider.cs (2)
76_checkRegistry = new ConcurrentBag<CheckFactoryContext>(); 397var tempColl = new ConcurrentBag<CheckFactoryContext>();
BuildCheck\Infrastructure\EditorConfig\EditorConfigParser.cs (2)
17private static ConcurrentBag<string> editorConfigFilePaths = new ConcurrentBag<string>(); 38editorConfigFilePaths = new ConcurrentBag<string>();
Evaluation\ParserIgnoreConfiguration.cs (2)
40private static ConcurrentBag<string> s_binlogEmbedPaths = new(); 48s_binlogEmbedPaths = new ConcurrentBag<string>();
Graph\GraphBuilder.cs (1)
640_projectReferrers.GetOrAdd(referenceInfo.ReferenceConfiguration, _ => new ConcurrentBag<string>())
Microsoft.Build.TaskAuthoring.Analyzer (7)
PreferTypedParameterAnalyzer.cs (1)
121var pendingDiagnostics = new ConcurrentBag<Diagnostic>();
TransitiveCallChainAnalyzer.cs (6)
175callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(calleeKey); 182callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(property.GetMethod.OriginalDefinition); 187callGraph.GetOrAdd(callerKey, _ => new ConcurrentBag<ISymbol>()).Add(property.SetMethod.OriginalDefinition); 206directViolations.GetOrAdd(callerKey, _ => new ConcurrentBag<ViolationInfo>()).Add(violation); 229directViolations.GetOrAdd(callerKey, _ => new ConcurrentBag<ViolationInfo>()).Add(violation); 253directViolations.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.NetAnalyzers (2)
Microsoft.CodeQuality.Analyzers\ApiDesignGuidelines\TypeNamesShouldNotMatchNamespaces.cs (2)
73var externallyVisibleNamedTypes = new ConcurrentBag<INamedTypeSymbol>(); 88var namespaceNamesInCompilation = new ConcurrentBag<string>();
Microsoft.DotNet.SourceBuild.Tasks (1)
src\UsageReport\WritePackageUsageData.cs (1)
184var 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>();
Microsoft.TestPlatform.CrossPlatEngine (1)
PostProcessing\PostProcessingTestRunAttachmentsProcessingEventsHandler.cs (1)
20private readonly ConcurrentBag<AttachmentSet> _attachmentsSet = new();
Microsoft.VisualStudio.TestPlatform.Common (1)
DataCollection\DataCollectionAttachmentManager.cs (1)
174_attachmentTasks.GetOrAdd(fileTransferInfo.Context, _ => new ConcurrentBag<Task>());
NuGet.Build.Tasks.Console (1)
MSBuildStaticGraphRestore.cs (1)
821var additionalMessages = new ConcurrentBag<IAssetsLogMessage>();
NuGet.Commands (3)
RestoreCommand\ProjectRestoreCommand.cs (1)
376var bag = new ConcurrentBag<RemoteMatch>(packagesToInstall);
RestoreCommand\RequestFactory\DependencyGraphSpecRequestProvider.cs (2)
84var requests = new ConcurrentBag<RestoreSummaryRequest>(); 85var toolRequests = new ConcurrentBag<RestoreSummaryRequest>();
System.Reflection.MetadataLoadContext (1)
System\Reflection\MetadataLoadContext.Disposing.cs (1)
11private ConcurrentBag<IDisposable> _disposables = new ConcurrentBag<IDisposable>();
187 references to ConcurrentBag
aspire (3)
Backchannel\AuxiliaryBackchannelMonitor.cs (2)
396var failedSockets = new ConcurrentBag<string>(); 487internal async Task TryConnectToSocketAsync(IAppHostSocket appHostSocket, ConcurrentBag<string> failedSockets, bool pruneOrphanedSockets, CancellationToken cancellationToken)
Documentation\ApiDocs\ApiDocsIndexService.cs (1)
633var loadedContainers = new ConcurrentBag<LoadedMemberContainer>();
aspire-tray (2)
NativeSmokeHarness.cs (2)
543internal ConcurrentBag<AppHostId> Stops { get; } = []; 544internal ConcurrentBag<string> Starts { get; } = [];
Aspire.Cli.Tests (8)
Acquisition\WingetRegistryProbeTests.cs (1)
67var errors = new ConcurrentBag<Exception>();
Commands\AddCommandTests.cs (1)
2120var searchSources = new ConcurrentBag<string[]>();
Commands\LsCommandTests.cs (1)
760var startedActivities = new ConcurrentBag<Activity>();
Git\GitRepositoryTests.cs (1)
118var startedActivities = new ConcurrentBag<Activity>();
Projects\GuestRuntimeTests.cs (2)
258var stoppedActivities = new ConcurrentBag<Activity>(); 961var stoppedActivities = new ConcurrentBag<Activity>();
TestServices\TerminalTapeTestHost.cs (1)
27private readonly ConcurrentBag<Hmp1ClientHandle> _clients = [];
Utils\DcpConnectionHealthCheckTests.cs (1)
174var seenUseDeveloperCertificateValues = new ConcurrentBag<bool>();
Aspire.Dashboard.Playwright.Tests (2)
tests\Aspire.Dashboard.Tests\Shared\TerminalTestProducer.cs (2)
14private readonly ConcurrentBag<Task<Hmp1ClientHandle>> _connections = []; 15private readonly ConcurrentBag<Task> _disconnections = [];
Aspire.Dashboard.Tests (3)
Shared\TerminalTestHost.cs (1)
25private readonly ConcurrentBag<Task> _attachmentDisposals = [];
Shared\TerminalTestProducer.cs (2)
14private readonly ConcurrentBag<Task<Hmp1ClientHandle>> _connections = []; 15private readonly ConcurrentBag<Task> _disconnections = [];
Aspire.Hosting (3)
ApplicationModel\EndpointAnnotation.cs (1)
407private readonly ConcurrentBag<NetworkEndpointSnapshot> _snapshots = new();
Dcp\DcpAppResourceStore.cs (1)
13private readonly ConcurrentBag<IAppResource> _resources = [];
Utils\ConcurrencyUtils.cs (1)
28public static void AddRange<T>(this ConcurrentBag<T> bag, IEnumerable<T> items)
Aspire.Hosting.Integration.Analyzers (20)
AspireExportAnalyzer.cs (20)
147var exportsByKey = new ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>>(); 150var capabilityIds = new ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>>(); 153var generatedMethodNames = new ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>>(); 246ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>> exportsByKey, 247ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds, 248ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames, 417var bag = exportsByKey.GetOrAdd(key, _ => new ConcurrentBag<(IMethodSymbol, Location)>()); 436ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds, 437ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames, 566ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds, 567ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames, 591ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds, 592ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames, 1689ConcurrentDictionary<(string ExportId, string TargetType), ConcurrentBag<(IMethodSymbol Method, Location Location)>> exportsByKey) 1711ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds) 1740ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames) 1770ConcurrentDictionary<string, ConcurrentBag<CapabilityExport>> capabilityIds, 1775var bag = capabilityIds.GetOrAdd(capabilityId, _ => []); 1780ConcurrentDictionary<(string MethodName, string TargetType), ConcurrentBag<GeneratedMethodNameExport>> generatedMethodNames, 1787var bag = generatedMethodNames.GetOrAdd((methodName, targetType), _ => []);
Aspire.Hosting.Tests (4)
Dcp\DcpExecutorTests.cs (1)
9751var failedResources = new ConcurrentBag<string>();
Dcp\DcpHostNotificationTests.cs (1)
455var activities = new ConcurrentBag<Activity>();
DistributedApplicationTests.cs (2)
136var activities = new ConcurrentBag<Activity>(); 168var activities = new ConcurrentBag<Activity>();
Aspire.Hosting.TestUtilities (10)
MockImageBuilder.cs (3)
19public ConcurrentBag<IResource> BuildImageResources { get; } = []; 20public ConcurrentBag<ContainerImageBuildOptions?> BuildImageOptions { get; } = []; 21public ConcurrentBag<IResource> PushImageCalls { get; } = [];
Publishing\FakeContainerRuntime.cs (7)
32public ConcurrentBag<(string localImageName, string targetImageName)> TagImageCalls { get; } = []; 33public ConcurrentBag<string> RemoveImageCalls { get; } = []; 34public ConcurrentBag<IResource> PushImageCalls { get; } = []; 35public ConcurrentBag<string> InspectImageConfigCalls { get; } = []; 36public ConcurrentBag<string> InspectImageManifestCalls { get; } = []; 37public ConcurrentBag<(string contextPath, string dockerfilePath, ContainerImageBuildOptions? options)> BuildImageCalls { get; } = []; 38public ConcurrentBag<(string registryServer, string username, string password)> LoginToRegistryCalls { get; } = [];
Aspire.Playground.Tests (3)
BlazorWasmHostingTests.cs (3)
61var otlpRequests = new ConcurrentBag<(string Url, int StatusCode)>(); 141var otlpRequests = new ConcurrentBag<(string Url, int StatusCode)>(); 179private static async Task WaitForOtlpSignalsAsync(IPage page, ConcurrentBag<(string Url, int StatusCode)> otlpRequests)
Aspire.TestUtilities (1)
TestLoggerFactory.cs (1)
13public ConcurrentBag<string> Categories { get; } = new();
ILCompiler.ReadyToRun (3)
Compiler\DependencyAnalysis\ReadyToRun\ManifestMetadataTableNode.cs (1)
70private ConcurrentBag<EcmaModule> _modulesWhichMustBeIndexable = new ConcurrentBag<EcmaModule>();
Compiler\DependencyAnalysis\ReadyToRun\TypeValidationChecker.cs (1)
20private ConcurrentBag<(TypeDesc type, string reason)> _typeLoadValidationErrors = new ConcurrentBag<(TypeDesc type, string reason)>();
Compiler\DependencyAnalysis\ReadyToRunCodegenNodeFactory.cs (1)
629private readonly ConcurrentBag<StringDiscoverableAssemblyStubNode> _stringDiscoverableStubs = new ConcurrentBag<StringDiscoverableAssemblyStubNode>();
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.Http.Extensions (11)
src\aspnetcore\src\Components\Endpoints\src\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;
src\aspnetcore\src\Components\Endpoints\src\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.Build (8)
BackEnd\Components\Communications\NodeProviderOutOfProc.cs (1)
90ConcurrentBag<NodeInfo> nodes = new();
BuildCheck\Infrastructure\BuildCheckManagerProvider.cs (3)
69private readonly ConcurrentBag<CheckFactoryContext> _checkRegistry; 397var tempColl = new ConcurrentBag<CheckFactoryContext>(); 510private readonly ConcurrentBag<BuildCheckRuleTelemetryData> _ruleTelemetryData = [];
BuildCheck\Infrastructure\EditorConfig\EditorConfigParser.cs (1)
17private static ConcurrentBag<string> editorConfigFilePaths = new ConcurrentBag<string>();
Evaluation\ParserIgnoreConfiguration.cs (1)
40private static ConcurrentBag<string> s_binlogEmbedPaths = new();
Graph\GraphBuilder.cs (2)
64private readonly ConcurrentDictionary<ConfigurationMetadata, ConcurrentBag<string>> _projectReferrers = new(); 556catch (InvalidProjectFileException ex) when (_projectReferrers.TryGetValue(configurationMetadata, out var referrers) && !referrers.IsEmpty)
Microsoft.Build.TaskAuthoring.Analyzer (16)
PreferTypedParameterAnalyzer.cs (7)
121var pendingDiagnostics = new ConcurrentBag<Diagnostic>(); 144ConcurrentBag<Diagnostic> pendingDiagnostics, 367ConcurrentBag<Diagnostic> pendingDiagnostics, 497ConcurrentBag<Diagnostic> pendingDiagnostics, 554ConcurrentBag<Diagnostic> pendingDiagnostics, 589ConcurrentBag<Diagnostic> pendingDiagnostics, 701ConcurrentBag<Diagnostic> pendingDiagnostics,
TransitiveCallChainAnalyzer.cs (9)
69var callGraph = new ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>>(SymbolEqualityComparer.Default); 70var directViolations = new ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>>(SymbolEqualityComparer.Default); 100ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>> callGraph, 101ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>> directViolations, 283ConcurrentDictionary<ISymbol, ConcurrentBag<ISymbol>> callGraph, 284ConcurrentDictionary<ISymbol, ConcurrentBag<ViolationInfo>> directViolations, 367if (callGraph.TryGetValue(methodKey, out var directCallees)) 389if (directViolations.TryGetValue(current, out var violations)) 408bool 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.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.NetAnalyzers (3)
Microsoft.CodeQuality.Analyzers\ApiDesignGuidelines\TypeNamesShouldNotMatchNamespaces.cs (3)
73var externallyVisibleNamedTypes = new ConcurrentBag<INamedTypeSymbol>(); 88var namespaceNamesInCompilation = new ConcurrentBag<string>(); 123private static bool AddNamespacesFromCompilation(ConcurrentBag<string> namespaceNamesInCompilation, INamespaceSymbol @namespace)
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
MSBuild\FileBasedProgramsProjectLoader.cs (1)
52public ConcurrentBag<IAsyncDisposable> Disposables { get; } = [];
Microsoft.DotNet.SourceBuild.Tasks (1)
src\UsageReport\WritePackageUsageData.cs (1)
184var 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;
Microsoft.NET.Sdk.StaticWebAssets.Tasks (1)
Data\StaticWebAssetEndpoint.cs (1)
396internal static ITaskItem[] ToTaskItems(ConcurrentBag<StaticWebAssetEndpoint> endpoints)
Microsoft.TestPlatform.CrossPlatEngine (1)
PostProcessing\PostProcessingTestRunAttachmentsProcessingEventsHandler.cs (1)
20private readonly ConcurrentBag<AttachmentSet> _attachmentsSet = new();
Microsoft.VisualStudio.TestPlatform.Common (3)
DataCollection\DataCollectionAttachmentManager.cs (3)
54private readonly ConcurrentDictionary<DataCollectionContext, ConcurrentBag<Task>> _attachmentTasks; 82_attachmentTasks = new ConcurrentDictionary<DataCollectionContext, ConcurrentBag<Task>>(); 140if (_attachmentTasks.TryGetValue(dataCollectionContext, out var tasks))
netstandard (1)
netstandard.cs (1)
94[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Collections.Concurrent.ConcurrentBag<>))]
NuGet.Build.Tasks.Console (3)
MSBuildStaticGraphRestore.cs (3)
821var additionalMessages = new ConcurrentBag<IAssetsLogMessage>(); 901ConcurrentBag<IAssetsLogMessage> additionalMessages) 924ConcurrentBag<IAssetsLogMessage> additionalMessages)
NuGet.Commands (3)
RestoreCommand\ProjectRestoreCommand.cs (1)
376var bag = new ConcurrentBag<RemoteMatch>(packagesToInstall);
RestoreCommand\RequestFactory\DependencyGraphSpecRequestProvider.cs (2)
84var requests = new ConcurrentBag<RestoreSummaryRequest>(); 85var toolRequests = new ConcurrentBag<RestoreSummaryRequest>();
System (1)
parent\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)
19/// duplicates. <see cref="ConcurrentBag{T}"/> is a thread-safe bag implementation, optimized for 23/// <see cref="ConcurrentBag{T}"/> accepts null reference (Nothing in Visual Basic) as a valid 27/// All public and protected members of <see cref="ConcurrentBag{T}"/> are thread-safe and may be used 42/// <summary>Initializes a new instance of the <see cref="ConcurrentBag{T}"/> class.</summary> 49/// Initializes a new instance of the <see cref="ConcurrentBag{T}"/> 53/// cref="ConcurrentBag{T}"/>.</param> 70/// Adds an object to the <see cref="ConcurrentBag{T}"/>. 73/// <see cref="ConcurrentBag{T}"/>. The value can be a null reference 80/// Attempts to add an object to the <see cref="ConcurrentBag{T}"/>. 83/// <see cref="ConcurrentBag{T}"/>. The value can be a null reference 93/// Attempts to remove and return an object from the <see cref="ConcurrentBag{T}"/>. 96/// removed from the <see cref="ConcurrentBag{T}"/> or the default value 106/// Attempts to return an object from the <see cref="ConcurrentBag{T}"/> without removing it. 109/// the <see cref="ConcurrentBag{T}"/> or the default value of 252/// Copies the <see cref="ConcurrentBag{T}"/> elements to an existing 258/// <see cref="ConcurrentBag{T}"/>. The <see 269/// cref="ConcurrentBag{T}"/> is greater than the available space from 332/// <see cref="ConcurrentBag{T}"/>. The <see 368/// Copies the <see cref="ConcurrentBag{T}"/> elements to a new array. 371/// cref="ConcurrentBag{T}"/>.</returns> 401/// Removes all values from the <see cref="ConcurrentBag{T}"/>. 446/// cref="ConcurrentBag{T}"/>. 449/// cref="ConcurrentBag{T}"/>.</returns> 460/// cref="ConcurrentBag{T}"/>. 463/// cref="ConcurrentBag{T}"/>.</returns> 472/// Gets the number of elements contained in the <see cref="ConcurrentBag{T}"/>. 474/// <value>The number of elements contained in the <see cref="ConcurrentBag{T}"/>.</value> 521/// Gets a value that indicates whether the <see cref="ConcurrentBag{T}"/> is empty. 523/// <value>true if the <see cref="ConcurrentBag{T}"/> is empty; otherwise, false.</value> 580/// with the SyncRoot; otherwise, false. For <see cref="ConcurrentBag{T}"/>, this property always 684/// <summary>Next queue in the <see cref="ConcurrentBag{T}"/>'s set of thread-local queues.</summary>
System.Reflection.MetadataLoadContext (2)
System\Reflection\MetadataLoadContext.Disposing.cs (2)
11private ConcurrentBag<IDisposable> _disposables = new ConcurrentBag<IDisposable>(); 34ConcurrentBag<IDisposable> disposables = _disposables;