77 references to Run
aspire (3)
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
236_ = Task.Run(async () => await DisconnectAsync(connection).ConfigureAwait(false), CancellationToken.None);
NuGet\NuGetPackagePrefetcher.cs (2)
26_ = Task.Run(async () => 51_ = Task.Run(async () =>
Aspire.Cli.Tests (1)
Commands\AgentMcpCommandTests.cs (1)
68_serverRunTask = Task.Run(async () =>
Aspire.Dashboard (6)
Model\TraceLinkHelpers.cs (1)
66var waitForTraceTask = Task.Run(async () =>
ServiceClient\DashboardClient.cs (5)
244_connection = Task.Run(() => ConnectAndWatchAsync(_clientCancellationToken), _clientCancellationToken); 254Task.Run(async () => 259Task.Run(async () => 465_ = Task.Run(async () => 700var readTask = Task.Run(async () =>
Aspire.Hosting (32)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)
702var task = Task.Run(async () => 838_ = Task.Run(async () =>
Backchannel\AuxiliaryBackchannelService.cs (1)
94_ = Task.Run(async () => await HandleClientConnectionAsync(clientSocket, stoppingToken).ConfigureAwait(false), stoppingToken);
Dashboard\DashboardService.cs (1)
71_ = Task.Run(async () =>
Dashboard\DashboardServiceData.cs (1)
38Task.Run(async () =>
Dcp\DcpExecutor.cs (12)
184var createServices = Task.Run(() => CreateAllDcpObjectsAsync<Service>(ct), ct); 186var getProxyAddresses = Task.Run(async () => 196var createContainerNetworks = Task.Run(() => CreateAllDcpObjectsAsync<ContainerNetwork>(ct), ct); 201var createExecutableEndpoints = Task.Run(async () => 209var createExecutables = Task.Run(async () => 216var createRegularContainers = Task.Run(async () => 229var createTunnel = Task.Run(async () => 244var createTunnelDependentContainers = Task.Run(async () => 713var task = Task.Run(async () => 974tasks.Add(Task.Run(async () => 1579tasks.Add(Task.Run(() => CreateResourceExecutablesAsyncCore(groupKey, groupList, createResourceFunc, cancellationToken), cancellationToken)); 2052tasks.Add(Task.Run(() => CreateContainerAsyncCore(cr, cancellationToken), cancellationToken));
Dcp\DcpHost.cs (1)
408_ = Task.Run(async () =>
Dcp\ResourceLogSource.cs (5)
93var startupStdoutStreamTask = Task.Run(() => StreamLogsAsync(startupStdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 96var startupStderrStreamTask = Task.Run(() => StreamLogsAsync(startupStderrStream, isError: false, parseDcpLogs: false), cancellationToken); 102var stdoutStreamTask = Task.Run(() => StreamLogsAsync(stdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 105var stderrStreamTask = Task.Run(() => StreamLogsAsync(stderrStream, isError: true, parseDcpLogs: false), cancellationToken); 110var systemStreamTask = Task.Run(() => StreamLogsAsync(systemStream, isError: false, parseDcpLogs: true), cancellationToken);
Devcontainers\DevcontainerSettingsWriter.cs (2)
63_processingTask = Task.Run(ProcessPortUpdatesAsync, _processingCancellation.Token); 193_ = Task.Run(async () =>
Eventing\DistributedApplicationEventing.cs (2)
40_ = Task.Run(async () => 56_ = Task.Run(async () =>
Exec\ExecResourceManager.cs (2)
95_ = Task.Run(async () => 102_ = Task.Run(async () =>
Health\ResourceHealthCheckService.cs (2)
54_ = Task.Run(async () => 248_ = Task.Run(async () =>
IInteractionService.cs (1)
167_currentTask = Task.Run(async () =>
Aspire.Hosting.Azure (1)
Provisioning\Provisioners\AzureProvisioner.cs (1)
154_ = Task.Run(() => ProvisionAzureResources(
Aspire.Hosting.Azure.AIFoundry (2)
AzureAIFoundryExtensions.cs (2)
199=> Task.Run(async () => 261_ = Task.Run(async () =>
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
Aspire.Hosting.Tests (1)
Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
aspire-server (2)
JsonRpcServer.cs (2)
107_ = Task.Run(() => HandleClientStreamAsync(pipeServer, ownsStream: true, cancellationToken), cancellationToken); 167_ = Task.Run(() => HandleClientStreamAsync(stream, ownsStream: true, cancellationToken), cancellationToken);
csc (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
CustomResources.AppHost (1)
TestResource.cs (1)
47Task.Run(async () =>
HealthChecksSandbox.AppHost (1)
Program.cs (1)
70Task.Run(
Microsoft.Build.Tasks.CodeAnalysis (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
Microsoft.Build.Tasks.CodeAnalysis.Sdk (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
Microsoft.CodeAnalysis (1)
DiagnosticAnalyzer\AnalyzerDriver.cs (1)
412_lazyInitializeTask = Task.Run(async () =>
Microsoft.CodeAnalysis.Features (2)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.cs (1)
86var task = Task.Run(workItem.Work, cancellationToken);
NavigateTo\INavigateToSearcherHost.cs (1)
105s_remoteHostHydrateTask = Task.Run(async () =>
Microsoft.CodeAnalysis.LanguageServer.Protocol (1)
src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\RequestExecutionQueue.cs (1)
381var currentWorkTask = WrapStartRequestTaskAsync(Task.Run(() => work.StartRequestAsync<TRequest, TResponse>(deserializedRequest, context, handler, cancellationToken), cancellationToken), rethrowExceptions: false);
Microsoft.CodeAnalysis.Remote.ServiceHub (1)
Host\SolutionAssetCache.cs (1)
64Task.Run(CleanAssetsAsync, CancellationToken.None);
Microsoft.CodeAnalysis.Workspaces (1)
CodeFixes\FixAllOccurrences\BatchFixAllProvider.cs (1)
222tasks.Add(Task.Run(
Microsoft.CommonLanguageServerProtocol.Framework.Package (1)
RequestExecutionQueue.cs (1)
381var currentWorkTask = WrapStartRequestTaskAsync(Task.Run(() => work.StartRequestAsync<TRequest, TResponse>(deserializedRequest, context, handler, cancellationToken), cancellationToken), rethrowExceptions: false);
Microsoft.Extensions.Diagnostics.Probes (1)
TcpEndpointProbesService.cs (1)
49_ = Task.Run(() => OpenTcpAsync(cancellationToken), cancellationToken);
Microsoft.Extensions.Hosting.Abstractions (1)
BackgroundService.cs (1)
46_executeTask = Task.Run(() => ExecuteAsync(_stoppingCts.Token), _stoppingCts.Token);
Microsoft.VisualStudio.IntegrationTest.Setup (1)
AsyncCompletionTracker.cs (1)
54_ = Task.Run(async () =>
Microsoft.VisualStudio.LanguageServices (3)
StackTraceExplorer\StackTraceExplorerViewModel.cs (1)
66System.Threading.Tasks.Task.Run(async () =>
SymbolSearch\VisualStudioSymbolSearchService.cs (1)
112Task.Run(() => UpdateSourceInBackgroundAsync(
ValueTracking\ValueTrackedTreeItemViewModel.cs (1)
145Task.Run(async () =>
Microsoft.VisualStudio.LanguageServices.Implementation (1)
SolutionExplorer\SourceGeneratedFileItems\SourceGeneratedFileItemSource.cs (1)
152Task.Run(
Nats.Backend (1)
Program.cs (1)
27_subscription = Task.Run(async () =>
Replay (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
RunTests (1)
ProcessRunner.cs (1)
112Task.Run(async () =>
Stress.ApiService (1)
Program.cs (1)
247_ = Task.Run(async () =>
Stress.AppHost (1)
TestResource.cs (1)
65Task.Run(async () =>
System.Private.CoreLib (1)
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)
5658return Run(function, default);
vbc (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
VBCSCompiler (1)
src\Compilers\Shared\BuildServerConnection.cs (1)
405await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);