184 references to Run
aspire (6)
Backchannel\AppHostCliBackchannel.cs (1)
406_ = Task.Run(async () =>
Backchannel\AuxiliaryBackchannelMonitor.cs (1)
517_ = Task.Run(async () => await DisconnectAsync(conn).ConfigureAwait(false));
Diagnostics\FileLoggerProvider.cs (1)
83_writerTask = Task.Run(ProcessLogQueueAsync);
Processes\IsolatedProcess.cs (1)
523var completion = Task.Run(() => RunAsync(reader, onLine));
Tui\TerminalViewerApp.cs (1)
586_ = Task.Run(async () =>
Utils\ConsoleActivityLogger.cs (1)
119_spinnerTask = Task.Run(async () =>
Aspire.Acquisition.Tests (1)
Scripts\Common\ScriptHostFixture.cs (1)
75_serverTask = Task.Run(() => ServeAsync(_cts!.Token));
Aspire.Cli.Tests (6)
DotNet\ProcessExecutionTests.cs (2)
50var releaseTask = Task.Run(async () => 110var releaseTask = Task.Run(async () =>
Interaction\SpectreConsoleLoggerProviderTests.cs (1)
169var promptTask = Task.Run(async () =>
NuGet\NuGetPackagePrefetcherTests.cs (1)
124_ = Task.Run(async () =>
Utils\OutputCollectorTests.cs (2)
80var readerTask = Task.Run(async () => 89var writerTask = Task.Run(async () =>
Aspire.Dashboard (11)
Components\Controls\Chart\ChartContainer.razor.cs (1)
71_tickTask = Task.Run(UpdateDataAsync);
Components\Interactions\InteractionsProvider.cs (2)
108_dialogDisplayTask = Task.Run(async () => 120_watchInteractionsTask = Task.Run(async () =>
Components\Pages\ConsoleLogs.razor.cs (3)
294_resourceSubscriptionTask = Task.Run(async () => 1047var consoleLogsTask = Task.Run(async () => 1167_ = Task.Run(async () =>
Components\Pages\Resources.razor.cs (1)
272_resourceSubscriptionTask = Task.Run(async () =>
DashboardWebApplication.cs (1)
425_ = Task.Run(async () =>
Model\ResourceOutgoingPeerResolver.cs (1)
39_watchTask = Task.Run(async () =>
Telemetry\DashboardTelemetrySender.cs (1)
45_sendLoopTask = Task.Run(async () =>
Utils\CallbackThrottler.cs (1)
127_ = Task.Run(ExecuteAsync);
Aspire.Dashboard.Tests (16)
ChannelExtensionsTests.cs (5)
38var readTask = Task.Run(async () => 64var readTask = Task.Run(async () => 88var readTask = Task.Run(async () => 113var readTask = Task.Run(async () => 157var readTask = Task.Run(async () =>
Model\DashboardClientTests.cs (4)
60var readTask = Task.Run(async () => 88var readTask = Task.Run(async () => 171var readTask = Task.Run(async () => 198var readTask = Task.Run(async () =>
TelemetryRepositoryTests\TelemetryRepositoryTests.cs (7)
392var watchTask = Task.Run(async () => 510var watchTask = Task.Run(async () => 976var watchTask = Task.Run(async () => 1067var watchTask = Task.Run(async () => 1150var watchTask = Task.Run(async () => 1252var watchTask = Task.Run(async () => 1349var watchTask = Task.Run(async () =>
Aspire.Hosting (16)
ApplicationModel\ResourceLoggerService.cs (1)
326var completionTask = Task.Run(async () =>
Dcp\DcpHost.cs (2)
285_logProcessorTask = Task.Run(() => StartLoggingSocketAsync(loggingSocket)); 454outputLoggers.Add(Task.Run(() => LogSocketOutputAsync(acceptedSocket, _shutdownCts.Token)));
Dcp\DcpResourceWatcher.cs (9)
121var watchResourcesTask = Task.Run(async () => 126Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 127Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 128Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, Model.Dcp.ContainerExecKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 129Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 130Task.Run(() => WatchKubernetesResourceAsync<Endpoint>(ProcessEndpointChange))).ConfigureAwait(false); 136var watchSubscribersTask = Task.Run(async () => 148var watchInformationChannelTask = Task.Run(async () => 630_ = Task.Run(async () =>
Dcp\Process\ProcessUtil.cs (1)
143_ = Task.Run(async () =>
Orchestrator\ParameterProcessor.cs (1)
85_parameterResolutionTask = Task.Run(async () =>
Pipelines\DistributedApplicationPipeline.cs (1)
945allStepTasks[i] = Task.Run(() => ExecuteStepWithDependencies(step));
Pipelines\PipelineActivityReporter.cs (1)
31_interactionServiceSubscriber = Task.Run(() => SubscribeToInteractionsAsync(_cancellationTokenSource.Token));
Aspire.Hosting.Azure (1)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)
143_ = Task.Run(async () =>
Aspire.Hosting.Azure.Kubernetes (1)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)
143_ = Task.Run(async () =>
Aspire.Hosting.Azure.Tests (1)
AzureDeployerTests.cs (1)
1902var runTask = Task.Run(() => app.RunAsync(cts.Token));
Aspire.Hosting.Browsers (1)
BrowserLogsCdpConnection.cs (1)
62_receiveLoop = Task.Run(ReceiveLoopAsync);
Aspire.Hosting.Browsers.Tests (4)
BrowserLogsSessionManagerTests.cs (1)
581serverTask = Task.Run(async () =>
BrowserPageSessionTests.cs (1)
315_ = Task.Run(async () =>
ConsoleLoggingTestHelpers.cs (1)
18_ = Task.Run(async () =>
src\Aspire.Hosting.Browsers\BrowserLogsCdpConnection.cs (1)
62_receiveLoop = Task.Run(ReceiveLoopAsync);
Aspire.Hosting.Docker (1)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)
143_ = Task.Run(async () =>
Aspire.Hosting.Maui (1)
Lifecycle\MauiBuildQueueEventSubscriber.cs (1)
393_ = Task.Run(async () =>
Aspire.Hosting.Maui.Tests (21)
MauiBuildQueueTests.cs (21)
54var eventTask = Task.Run(() => env.Eventing.PublishAsync( 87var task1 = Task.Run(() => env.Eventing.PublishAsync( 94var task2 = Task.Run(() => env.Eventing.PublishAsync( 115var task1 = Task.Run(() => env.Eventing.PublishAsync( 136var task2 = Task.Run(() => env.Eventing.PublishAsync( 170var eventTask = Task.Run(() => env.Eventing.PublishAsync( 187var task1 = Task.Run(() => env.Eventing.PublishAsync( 191var task2 = Task.Run(() => env.Eventing.PublishAsync( 232var task1 = Task.Run(() => env.Eventing.PublishAsync( 240var task2 = Task.Run(() => env.Eventing.PublishAsync( 267var task1 = Task.Run(async () => 280var task2 = Task.Run(async () => 288var task3 = Task.Run(async () => 348var task1 = Task.Run(() => env.Eventing.PublishAsync( 515var task1 = Task.Run(() => env.Eventing.PublishAsync( 523var task2 = Task.Run(() => env.Eventing.PublishAsync( 554var eventTask = Task.Run(() => env.Eventing.PublishAsync( 611var task1 = Task.Run(() => env.Eventing.PublishAsync( 673var task1 = Task.Run(() => env.Eventing.PublishAsync( 683var task2 = Task.Run(() => env.Eventing.PublishAsync( 687var task3 = Task.Run(() => env.Eventing.PublishAsync(
Aspire.Hosting.Testing.Tests (3)
ResourceLoggerForwarderServiceTests.cs (2)
40var subscriberLoop = Task.Run(async () => 79var subscriberLoop = Task.Run(async () =>
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
15_ = Task.Run(async () =>
Aspire.Hosting.Tests (36)
ApplicationModel\ResourceAnnotationCollectionTests.cs (2)
189var modifierTask = Task.Run(async () => 218var enumeratorTasks = Enumerable.Range(0, 4).Select(i => Task.Run(async () =>
Backchannel\AppHostRpcTargetCancellationTests.cs (6)
53var iterationTask = Task.Run(async () => 77var iterationTask = Task.Run(async () => 126var iterationTask = Task.Run(async () => 149var iterationTask = Task.Run(async () => 197var iterationTask = Task.Run(async () => 220var iterationTask = Task.Run(async () =>
Backchannel\AuxiliaryBackchannelRpcTargetTests.cs (1)
2115var collectTask = Task.Run(async () =>
Backchannel\GetTerminalInfoAsyncTests.cs (1)
399_acceptLoop = Task.Run(() => AcceptLoopAsync(_cts.Token));
Dashboard\DashboardResourceTests.cs (1)
707var watchForLogSubs = Task.Run(async () =>
Dashboard\ResourcePublisherTests.cs (2)
57var task = Task.Run(async () => 182var task = Task.Run(async () =>
Dcp\DcpExecutorTests.cs (1)
159var watchResourceTask = Task.Run(async () =>
EndpointReferenceTests.cs (2)
397Task.Run(async() => 403Task.Run(async () =>
InteractionServiceTests.cs (3)
127var readTask = Task.Run(async () => 900var readTask = Task.Run(async () => 953var readTask = Task.Run(async () =>
Orchestrator\ApplicationOrchestratorTests.cs (9)
47var watchResourceTask = Task.Run(async () => 95var watchResourceTask = Task.Run(async () => 195var watchResourceTask = Task.Run(async () => 261var watchResourceTask = Task.Run(async () => 313var watchResourceTask = Task.Run(async () => 473var watchResourceTask = Task.Run(async () => 1418var watchResourceTask = Task.Run(async () => 1475var watchResourceTask = Task.Run(async () => 1529var watchResourceTask = Task.Run(async () =>
Orchestrator\ParameterProcessorTests.cs (1)
87var watchTask = Task.Run(async () =>
Pipelines\PipelineLoggerProviderTests.cs (2)
94var task1 = Task.Run(async () => 102var task2 = Task.Run(async () =>
Publishing\DeploymentStateManagerTests.cs (1)
118tasks.Add(Task.Run(async () =>
ResourceLoggerServiceTests.cs (1)
810return Task.Run(async () =>
tests\Shared\ConsoleLogging\ConsoleLoggingTestHelpers.cs (1)
15_ = Task.Run(async () =>
WithUrlsTests.cs (2)
476var watchTask = Task.Run(async () => 592var watchTask = Task.Run(async () =>
Aspire.Managed.Tests (1)
ParentProcessWatchdogTests.cs (1)
71var cancellationTask = Task.Run(() => ParentProcessWatchdog.CancelAndForceExitAsync(
Aspire.RabbitMQ.Client.Tests (1)
ConformanceTests.cs (1)
127Task.Run(async () =>
Aspire.TerminalHost (1)
TerminalHostControlListener.cs (1)
114_acceptLoop = Task.Run(() => AcceptLoopAsync(_disposeCts.Token));
Client.ChannelLayer.IntegrationTests (1)
DuplexChannelWithSynchronizationContext.cs (1)
266Task.Run(async () =>
dotnet (4)
Commands\Restore\RestoringCommand.cs (1)
44Task.Run(() => WorkloadManifestUpdater.BackgroundUpdateAdvertisingManifestsAsync(userProfileDir));
Commands\Test\MTP\TestApplication.cs (2)
96? Task.Run(async () => await WaitConnectionAsync(cancellationToken)) 99? Task.Run(async () => await WaitControlConnectionAsync(cancellationToken))
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
39_readers[i] = Task.Run(async () => await Read(
dotnet-svcutil-lib (1)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageContent.cs (1)
184Task.Run(async () => await _messageEncoder.WriteMessageAsync(_message, bufferedStream));
ILCompiler.DependencyAnalysisFramework (1)
src\runtime\src\coreclr\tools\Common\Sorting\MergeSortCore.cs (1)
42Task rightSortTask = Task.Run(() => ParallelSort(arrayToSort, index + halfLen, length - halfLen, comparer));
Infrastructure.Tests (1)
PowerShellScripts\DownloadNativeArchivesTests.cs (1)
537_serverTask = Task.Run(() => RunAsync(_cts.Token));
Microsoft.AspNetCore.HttpLogging (1)
FileLoggerProcessor.cs (1)
103_outputTask = Task.Run(ProcessLogQueue);
Microsoft.AspNetCore.Server.HttpSys (1)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.IIS (1)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Core (2)
Internal\Http2\Http2FrameWriter.cs (1)
161_writeQueueTask = Task.Run(WriteToOutputPipe);
src\aspnetcore\src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Transport.NamedPipes (3)
Internal\NamedPipeConnectionListener.cs (2)
81listeningTasks[i] = Task.Run(() => StartAsync(initialStream)); 84_completeListeningTask = Task.Run(async () =>
src\aspnetcore\src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\aspnetcore\src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.Build (2)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (1)
973cleanupTasks[idx++] = Task.Run(async () =>
BackEnd\TaskExecutionHost\TaskExecutionHost.cs (1)
895Task.Run(async delegate
Microsoft.CodeAnalysis.Workspaces.MSBuild (1)
MSBuild\BuildHostProcessManager.cs (1)
209Task.Run(async () =>
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
Rpc\RpcServer.cs (1)
109var runningTask = Task.Run(() => ProcessRequestAsync(request));
Microsoft.DotNet.Cli.Telemetry (2)
PersistentStorageLogExporter.cs (1)
105_drainTask = Task.Run(async () =>
PersistentStorageTraceExporter.cs (1)
113_drainTask = Task.Run(async () =>
Microsoft.DotNet.Cli.Utils (1)
FileAccessRetrier.cs (1)
95Task.Run(() => Task.Delay(nextWaitTime)).Wait();
Microsoft.Extensions.AsyncState.Tests (3)
AsyncContextTests.cs (1)
255tasks[i] = Task.Run(setAsyncState);
AsyncStateTests.cs (2)
51var task = Task.Run(async () => 101var task = Task.Run(async () =>
Microsoft.Extensions.DependencyInjection (1)
ServiceLookup\ServiceProviderEngineScope.cs (1)
116Task.Run(() => ((IAsyncDisposable)localService).DisposeAsync().AsTask()).GetAwaiter().GetResult();
Microsoft.Extensions.Logging.AzureAppServices (1)
BatchingLoggerProvider.cs (1)
162_outputTask = Task.Run(ProcessLogQueue);
Microsoft.Extensions.ML (1)
ModelLoaders\UriModelLoader.cs (1)
58_ = Task.Run(async () =>
Microsoft.Extensions.ServiceDiscovery.Dns.Tests (1)
Resolver\RetryTests.cs (1)
19return Task.Run(async () =>
Microsoft.ML.AutoML.Interactive (1)
NotebookMonitor.cs (1)
74Task.Run(async () => await _updateThrottler.ExecuteAsync());
Microsoft.ML.AutoML.Tests (2)
StopTrainingManagerTests.cs (2)
56var waitForCompleted = Task.Run(async () => 83var waitForCompleted = Task.Run(async () =>
Microsoft.NET.Sdk.Publish.Tasks (1)
Kudu\KuduVfsDeploy.cs (1)
52return System.Threading.Tasks.Task.Run(
Microsoft.TemplateEngine.Cli (2)
Commands\create\InstantiateCommand.TabCompletion.cs (2)
146Task.Run(async () => 193Task.Run(async () =>
Microsoft.TemplateEngine.Orchestrator.RunnableProjects (1)
RunnableProjectGenerator.cs (1)
271Task.Run(async () => await loadedTemplate.ValidateAsync(ValidationScope.Instantiation, CancellationToken.None).ConfigureAwait(false)).GetAwaiter().GetResult();
Microsoft.TestPlatform.CommunicationUtilities (2)
SocketClient.cs (1)
107Task.Run(() => _tcpClient.MessageLoopAsync(
SocketServer.cs (1)
180_ = Task.Run(() => client.MessageLoopAsync(_channel, error => StopOnError(error), _cancellation.Token));
NuGet.PackageManagement (1)
IDE\PackageRestoreManager.cs (1)
511tasks.Add(Task.Run(() => CopySatelliteFilesRunnerAsync(packageReferencesQueue, packageRestoreContext, nuGetProjectContext)));
NuGet.Protocol (1)
Plugins\OutboundRequestContext`1.cs (1)
276Task.Run(async () =>
ScenarioTests.Common.Tests (3)
ScenarioTestTypes.cs (3)
973Task.Run(async () => 984Task.Run(async () => 995Task.Run(async () =>
Stress.ApiService (2)
ProducerConsumer.cs (1)
26var consumerTask = Task.Run(async () =>
TestMetrics.cs (1)
36Task.Run(async () =>
System.Windows.Forms (1)
System\Windows\Forms\Controls\PictureBox\PictureBox.cs (1)
481Task.Run(async () =>
Testing.Tests (5)
WaitFailures.cs (5)
66_ = Task.Run(async () => 154_ = Task.Run(async () => 174_ = Task.Run(async () => 226_ = Task.Run(async () => 250_ = Task.Run(async () =>
TestProject.AppHost (1)
Program.cs (1)
8_ = Task.Run(async () =>
VBCSCompiler (1)
src\roslyn\src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (1)
73var task = Task.Run(() => ListenCoreAsync(PipeName, Logger, _queue, _cancellationTokenSource.Token));