98 references to Run
aspire (7)
Backchannel\AuxiliaryBackchannelMonitor.cs (2)
91_ = Task.Run(async () => 332_ = Task.Run(async () => await DisconnectAsync(connection).ConfigureAwait(false), CancellationToken.None);
Commands\PsCommand.cs (1)
194_ = Task.Run(async () =>
Commands\RenderCommand.cs (1)
412var loggingTask = Task.Run(async () =>
Interaction\ExtensionInteractionService.cs (1)
62PumpTask = Task.Run(ProcessExtensionTaskChannelAsync, CancellationToken.None);
NuGet\NuGetPackagePrefetcher.cs (2)
36prefetchTasks.Add(Task.Run(async () => 65prefetchTasks.Add(Task.Run(async () =>
Aspire.Cli.Tests (1)
Commands\AgentMcpCommandTests.cs (1)
78var serverRunTask = Task.Run(async () =>
Aspire.Dashboard (8)
Model\TraceLinkHelpers.cs (1)
66var waitForTraceTask = Task.Run(async () =>
ServiceClient\DashboardClient.cs (5)
327_connection = Task.Run(() => ConnectAndWatchAsync(_clientCancellationToken), _clientCancellationToken); 340Task.Run(async () => 345Task.Run(async () => 674_ = Task.Run(async () => 915var readTask = Task.Run(async () =>
Terminal\TerminalWebSocketProxy.cs (2)
282var inbound = Task.Run(async () => 333var outbound = Task.Run(async () =>
Aspire.Hosting (27)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (2)
1633var task = Task.Run(async () => 1849_ = Task.Run(async () =>
Backchannel\AuxiliaryBackchannelService.cs (1)
104_ = Task.Run(async () => await HandleClientConnectionAsync(clientSocket, stoppingToken).ConfigureAwait(false), stoppingToken);
Dashboard\DashboardService.cs (1)
81_ = Task.Run(async () =>
Dashboard\DashboardServiceData.cs (1)
41Task.Run(async () =>
Dcp\DcpExecutor.cs (8)
196var createServices = Task.Run(() => CreateAllDcpObjectsAsync<Service>(ct), ct); 198var getProxyAddresses = Task.Run(async () => 208var createContainerNetworks = Task.Run(() => CreateAllDcpObjectsAsync<ContainerNetwork>(ct), ct); 210var createWorkloadEndpoints = Task.Run(async () => 247var createExecutables = Task.Run(async () => 258var createContainers = Task.Run(async () => 632tasks.Add(Task.Run(async () => 908tasks.Add(Task.Run(() => CreateResourceReplicasAsync(groupKey, groupList, creator, context, cancellationToken), cancellationToken));
Dcp\DcpHost.cs (1)
595_ = Task.Run(async () =>
Dcp\ResourceLogSource.cs (5)
111var startupStdoutStreamTask = Task.Run(() => StreamLogsAsync(startupStdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 114var startupStderrStreamTask = Task.Run(() => StreamLogsAsync(startupStderrStream, isError: false, parseDcpLogs: false), cancellationToken); 120var stdoutStreamTask = Task.Run(() => StreamLogsAsync(stdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 123var stderrStreamTask = Task.Run(() => StreamLogsAsync(stderrStream, isError: true, parseDcpLogs: false), cancellationToken); 128var 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)
41_ = Task.Run(async () => 57_ = Task.Run(async () =>
Health\ResourceHealthCheckService.cs (2)
54_ = Task.Run(async () => 260_ = Task.Run(async () =>
IInteractionService.cs (1)
192_currentTask = Task.Run(async () =>
Lifecycle\TerminalHostOrphanCleanupService.cs (1)
102_cleanupTask = Task.Run(
Aspire.Hosting.Azure (3)
AzureProvisioningController.cs (3)
1443_ = Task.Run(async () => 1471_ = Task.Run(async () => 1624_ = Task.Run(async () =>
Aspire.Hosting.Blazor (1)
BlazorGatewayExtensions.cs (1)
413_ = Task.Run(() => WatchGatewayStateAsync(gateway.Resource, notificationService, ct), ct);
Aspire.Hosting.Foundry (3)
FoundryExtensions.cs (2)
288=> Task.Run(async () => 348_ = Task.Run(async () =>
PromptAgent\AzurePromptAgentResource.cs (1)
308_ = Task.Run(async () =>
Aspire.Hosting.Maui.Tests (2)
MauiBuildQueueTests.cs (2)
124_ = Task.Run(async () => 158_ = Task.Run(async () =>
Aspire.Hosting.RemoteHost (2)
JsonRpcServer.cs (2)
119_ = Task.Run(() => HandleClientStreamAsync(pipeServer, ownsStream: true, cancellationToken), cancellationToken); 181_ = Task.Run(() => HandleClientStreamAsync(stream, ownsStream: true, cancellationToken), cancellationToken);
Aspire.Hosting.Testing.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
Aspire.Hosting.Tests (2)
Backchannel\GetTerminalInfoAsyncTests.cs (1)
417_ = Task.Run(async () =>
Orchestrator\ApplicationOrchestratorTests.cs (1)
972var forceStartTask = Task.Run(async () =>
Aspire.Hosting.TestUtilities (1)
Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
Aspire.Playground.Tests (1)
tests\Aspire.Hosting.TestUtilities\Utils\LoggerNotificationExtensions.cs (1)
84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);
Aspire.TerminalHost (3)
DcpUpstreamAdapter.cs (1)
236_readPump = Task.Run(() => ReadPumpAsync(_disposeCts.Token), _disposeCts.Token);
TerminalHostControlListener.cs (1)
195_ = Task.Run(() => ServeClientAsync(client, cancellationToken), cancellationToken);
TerminalReplica.cs (1)
183_runTask = Task.Run(() => RecycleLoopAsync(_stopCts.Token), _stopCts.Token);
csc (1)
src\roslyn\src\Compilers\Shared\BuildServerConnection.cs (1)
414await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
CustomResources.AppHost (1)
TestResource.cs (1)
48Task.Run(async () =>
dotnet (2)
Commands\Test\MTP\IPC\NamedPipeServer.cs (1)
54_loopTask = Task.Run(
src\sdk\artifacts\.packages\microsoft.codeanalysis.buildclient\5.11.0-1.26424.106\contentFiles\cs\net11.0\BuildServerConnection.cs (1)
414await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
HealthChecksSandbox.AppHost (1)
AppHost.cs (1)
130Task.Run(
Microsoft.Build (3)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (2)
514Task.Run( 890tasks[idx++] = Task.Run(
Graph\ParallelWorkSet.cs (1)
163return Task.Run(
Microsoft.Build.Tasks.CodeAnalysis (1)
src\roslyn\src\Compilers\Shared\BuildServerConnection.cs (1)
414await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
Microsoft.Build.Tasks.Core (3)
AssemblyDependency\Node\OutOfProcRarNode.cs (2)
89Task nodeEndpointTasks = Task.Run(() => RunNodeEndpointsAsync(linkedCts.Token), linkedCts.Token); 143endpointTasks[i] = Task.Run(() => endpoint.RunAsync(cancellationToken), cancellationToken);
AssemblyDependency\Node\OutOfProcRarNodeEndpoint.cs (1)
66Task logEventTask = Task.Run(
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.Workspaces (1)
CodeFixes\FixAllOccurrences\BatchFixAllProvider.cs (1)
222tasks.Add(Task.Run(
Microsoft.DotNet.HotReload.Utils.Generator (1)
BaselineProject.cs (1)
67var t = Task.Run (async () => {
Microsoft.DotNet.HotReload.Watch (3)
HotReload\RunningProjectsManager.cs (1)
276_ = Task.Run(async () =>
src\sdk\src\Dotnet.Watch\HotReloadClient\HotReloadClient.cs (1)
152_pendingUpdates = Task.Run(async () =>
src\sdk\src\Dotnet.Watch\HotReloadClient\Web\AbstractBrowserRefreshServer.cs (1)
164var progressReportingTask = Task.Run(async () =>
Microsoft.Extensions.Diagnostics.Probes (1)
TcpEndpointProbesService.cs (1)
49_ = Task.Run(() => OpenTcpAsync(cancellationToken), cancellationToken);
Microsoft.Extensions.DotNetDeltaApplier (1)
src\sdk\src\Dotnet.Watch\HotReloadAgent.Host\Listener.cs (1)
53return Task.Run(async () =>
Microsoft.Extensions.Hosting.Abstractions (1)
BackgroundService.cs (1)
49: Task.Run(() => ExecuteAsync(stoppingToken), CancellationToken.None);
Microsoft.Extensions.Http.Diagnostics (1)
Logging\Internal\HttpResponseBodyReader.cs (1)
207=> Task.Run(() => WriteStreamToPipeImplAsync(stream, writer, cancellationToken), CancellationToken.None);
Microsoft.TestPlatform.VsTestConsole.TranslationLayer (1)
VsTestConsoleRequestSender.cs (1)
135await Task.Run(() =>
MSBuild.Coordinator (1)
CoordinatorServer.cs (1)
92Task clientTask = Task.Run(() => HandleTrackedClientAsync(pipeStream, token), CancellationToken.None);
Nats.Backend (1)
Program.cs (1)
23_subscription = Task.Run(async () =>
NuGet.PackageManagement (1)
PackageDownloader.cs (1)
172var remainingTasks = Task.Run(async () =>
NuGet.Protocol (3)
Plugins\AutomaticProgressReporter.cs (1)
170Task.Run(async () =>
Plugins\InboundRequestContext.cs (1)
194Task.Run(async () =>
Plugins\InboundRequestProcessingHandler.cs (1)
59Task.Run(task, cancellationToken);
Stress.ApiService (1)
Program.cs (1)
277_ = Task.Run(async () =>
Stress.AppHost (1)
TestResource.cs (1)
145Task.Run(async () =>
System.Private.CoreLib (1)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (1)
5759return Run(function, default);
vbc (1)
src\roslyn\src\Compilers\Shared\BuildServerConnection.cs (1)
414await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);
VBCSCompiler (1)
src\roslyn\src\Compilers\Shared\BuildServerConnection.cs (1)
414await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);