Run

87 references to Run

aspire (4)

DotNet\DotNetCliRunner.cs (2)

580var pendingStdoutStreamForwarder = Task.Run(async () => { 589var pendingStderrStreamForwarder = Task.Run(async () => {

NuGet\NuGetPackagePrefetcher.cs (2)

26_ = Task.Run(async () => 51_ = 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 () => 446_ = Task.Run(async () => 669var readTask = Task.Run(async () =>

Aspire.Hosting (21)

Dashboard\DashboardService.cs (1)

71_ = Task.Run(async () =>

Dashboard\DashboardServiceData.cs (1)

38Task.Run(async () =>

Dcp\DcpExecutor.cs (3)

594var task = Task.Run(async () => 1197tasks.Add(Task.Run(() => CreateResourceExecutablesAsyncCore(groupKey, groupList, cancellationToken), cancellationToken)); 1496tasks.Add(Task.Run(() => CreateContainerAsyncCore(cr, cancellationToken), cancellationToken));

Dcp\DcpHost.cs (1)

389_ = Task.Run(async () =>

Dcp\ResourceLogSource.cs (5)

40var startupStdoutStreamTask = Task.Run(() => StreamLogsAsync(startupStdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 43var startupStderrStreamTask = Task.Run(() => StreamLogsAsync(startupStderrStream, isError: false, parseDcpLogs: false), cancellationToken); 49var stdoutStreamTask = Task.Run(() => StreamLogsAsync(stdoutStream, isError: false, parseDcpLogs: false), cancellationToken); 52var stderrStreamTask = Task.Run(() => StreamLogsAsync(stderrStream, isError: true, parseDcpLogs: false), cancellationToken); 57var 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 () =>

ResourceBuilderExtensions.cs (1)

2077_ = Task.Run(async () =>

Aspire.Hosting.Azure (1)

Provisioning\Provisioners\AzureProvisioner.cs (1)

156_ = 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 (3)

Utils\LoggerNotificationExtensions.cs (1)

84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);

WithHttpCommandTests.cs (2)

382var watchTask = Task.Run(async () => 452var watchTask = Task.Run(async () =>

Aspire.Playground.Tests (1)

tests\Aspire.Hosting.Tests\Utils\LoggerNotificationExtensions.cs (1)

84_ = Task.Run(() => WatchNotifications(app, resourceName, predicate, tcs, watchCts), watchCts.Token);

csc (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);

CustomResources.AppHost (1)

TestResource.cs (1)

47Task.Run(async () =>

dotnet (2)

BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);

Commands\Test\MTP\IPC\NamedPipeServer.cs (1)

54_loopTask = Task.Run(

dotnet.Tests (2)

CommandTests\Test\IPCTests.cs (2)

79var clientConnected = Task.Run( 183waitConnectionTask.Add(Task.Run(

dotnet-watch (2)

AbstractBrowserRefreshServer.cs (1)

146var progressReportingTask = Task.Run(async () =>

HotReloadClient.cs (1)

118_pendingUpdates = Task.Run(async () =>

dotnet-watch.Tests (1)

HotReload\RuntimeProcessLauncherTests.cs (1)

123var watchTask = Task.Run(async () =>

HealthChecksSandbox.AppHost (1)

Program.cs (1)

70Task.Run(

Microsoft.Build (3)

BackEnd\Components\ProjectCache\ProjectCacheService.cs (2)

514Task.Run( 860tasks[idx++] = Task.Run(

Graph\ParallelWorkSet.cs (1)

163return Task.Run(

Microsoft.Build.Tasks.CodeAnalysis (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);

Microsoft.Build.Tasks.CodeAnalysis.Sdk (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);

Microsoft.Build.Tasks.Core (2)

AssemblyDependency\Node\OutOfProcRarNode.cs (2)

90Task nodeEndpointTasks = Task.Run(() => RunNodeEndpointsAsync(linkedCts.Token), linkedCts.Token); 144endpointTasks[i] = Task.Run(() => endpoint.RunAsync(cancellationToken), cancellationToken);

Microsoft.CodeAnalysis (1)

DiagnosticAnalyzer\AnalyzerDriver.cs (1)

412_lazyInitializeTask = Task.Run(async () =>

Microsoft.CodeAnalysis.Features (2)

ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.cs (1)

79var task = Task.Run(taskCreator, cancellationToken);

NavigateTo\INavigateToSearcherHost.cs (1)

105s_remoteHostHydrateTask = Task.Run(async () =>

Microsoft.CodeAnalysis.LanguageServer.Protocol (1)

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\RequestExecutionQueue.cs (1)

378var currentWorkTask = WrapStartRequestTaskAsync(Task.Run(() => work.StartRequestAsync<TRequest, TResponse>(deserializedRequest, context, handler, metadata.Language, 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)

Microsoft.DotNet.HotReload.Client.Package (2)

HotReloadClient.cs (1)

118_pendingUpdates = Task.Run(async () =>

Web\AbstractBrowserRefreshServer.cs (1)

146var progressReportingTask = Task.Run(async () =>

Microsoft.DotNet.HotReload.Client.Tests (2)

AbstractBrowserRefreshServer.cs (1)

146var progressReportingTask = Task.Run(async () =>

HotReloadClient.cs (1)

118_pendingUpdates = Task.Run(async () =>

Microsoft.Extensions.Diagnostics.Probes (1)

TcpEndpointProbesService.cs (1)

49_ = Task.Run(() => OpenTcpAsync(cancellationToken), cancellationToken);

Microsoft.Extensions.DotNetDeltaApplier (1)

PipeListener.cs (1)

55return Task.Run(async () =>

Microsoft.Extensions.DotNetDeltaApplier.Tests (2)

AbstractBrowserRefreshServer.cs (1)

146var progressReportingTask = Task.Run(async () =>

HotReloadClient.cs (1)

118_pendingUpdates = Task.Run(async () =>

Microsoft.Extensions.Hosting.Abstractions (1)

BackgroundService.cs (1)

46_executeTask = Task.Run(() => ExecuteAsync(_stoppingCts.Token), _stoppingCts.Token);

Microsoft.Extensions.Http.Diagnostics (1)

Logging\Internal\HttpResponseBodyReader.cs (1)

205=> Task.Run(() => WriteStreamToPipeImplAsync(stream, writer, cancellationToken), CancellationToken.None);

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(

Microsoft.VisualStudio.LanguageServices.Xaml (1)

Implementation\LanguageServer\Handler\Definitions\GoToDefinitionHandler.cs (1)

76var task = Task.Run(async () =>

Nats.Backend (1)

Program.cs (1)

27_subscription = Task.Run(async () =>

Replay (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await 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)

5596return Run(function, default);

vbc (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);

VBCSCompiler (1)

src\Compilers\Shared\BuildServerConnection.cs (1)

398await Task.Run(() => pipeStream.ConnectAsync(timeoutMs, cancellationToken), cancellationToken).ConfigureAwait(false);