217 references to Run
aspire (2)
Interaction\ExtensionInteractionService.cs (1)
47_ = Task.Run(async () =>
Utils\ConsoleActivityLogger.cs (1)
101_spinnerTask = Task.Run(async () =>
Aspire.Cli.Tests (2)
Utils\OutputCollectorTests.cs (2)
79var readerTask = Task.Run(async () => 88var writerTask = Task.Run(async () =>
Aspire.Dashboard (12)
Components\Controls\Chart\ChartContainer.razor.cs (1)
71_tickTask = Task.Run(UpdateDataAsync);
Components\Interactions\InteractionsProvider.cs (2)
107_dialogDisplayTask = Task.Run(async () => 119_watchInteractionsTask = Task.Run(async () =>
Components\Pages\ConsoleLogs.razor.cs (3)
270_resourceSubscriptionTask = Task.Run(async () => 751var consoleLogsTask = Task.Run(async () => 889_ = Task.Run(async () =>
Components\Pages\Resources.razor.cs (1)
279_resourceSubscriptionTask = Task.Run(async () =>
DashboardWebApplication.cs (1)
391_ = Task.Run(async () =>
Model\Assistant\AIContextProvider.cs (1)
106_ = Task.Run(() => ExecuteSubscriptionsAsync(subscriptions));
Model\ResourceOutgoingPeerResolver.cs (1)
34_watchTask = Task.Run(async () =>
Telemetry\DashboardTelemetrySender.cs (1)
45_sendLoopTask = Task.Run(async () =>
Utils\CallbackThrottler.cs (1)
127_ = Task.Run(ExecuteAsync);
Aspire.Dashboard.Tests (8)
ChannelExtensionsTests.cs (4)
25var readTask = Task.Run(async () => 49var readTask = Task.Run(async () => 74var readTask = Task.Run(async () => 118var readTask = Task.Run(async () =>
Model\DashboardClientTests.cs (4)
55var readTask = Task.Run(async () => 83var readTask = Task.Run(async () => 166var readTask = Task.Run(async () => 193var readTask = Task.Run(async () =>
Aspire.Hosting (14)
ApplicationModel\ResourceLoggerService.cs (1)
306var completionTask = Task.Run(async () =>
Dcp\DcpExecutor.cs (8)
251var watchResourcesTask = Task.Run(async () => 256Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 257Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, "Container", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 258Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, "ContainerExec", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 259Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 260Task.Run(() => WatchKubernetesResourceAsync<Endpoint>(ProcessEndpointChange))).ConfigureAwait(false); 266var watchSubscribersTask = Task.Run(async () => 278var watchInformationChannelTask = Task.Run(async () =>
Dcp\DcpHost.cs (2)
153_logProcessorTask = Task.Run(() => StartLoggingSocketAsync(loggingSocket)); 253outputLoggers.Add(Task.Run(() => LogSocketOutputAsync(acceptedSocket, _shutdownCts.Token)));
Orchestrator\ParameterProcessor.cs (1)
53var parameterResolutionTask = Task.Run(async () =>
Pipelines\DistributedApplicationPipeline.cs (1)
293allStepTasks[i] = Task.Run(() => ExecuteStepWithDependencies(step));
Pipelines\PipelineActivityReporter.cs (1)
29_interactionServiceSubscriber = Task.Run(() => SubscribeToInteractionsAsync(_cancellationTokenSource.Token));
Aspire.Hosting.Azure (1)
Provisioning\Internal\RunModeProvisioningContextProvider.cs (1)
74_ = Task.Run(async () =>
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
61var subscriberLoop = Task.Run(async () =>
Aspire.Hosting.Tests (23)
Dashboard\DashboardResourceTests.cs (1)
475var watchForLogSubs = Task.Run(async () =>
Dashboard\ResourcePublisherTests.cs (2)
37var task = Task.Run(async () => 162var task = Task.Run(async () =>
Dcp\DcpExecutorTests.cs (1)
94var watchResourceTask = Task.Run(async () =>
InteractionServiceTests.cs (3)
125var readTask = Task.Run(async () => 816var readTask = Task.Run(async () => 869var readTask = Task.Run(async () =>
Orchestrator\ApplicationOrchestratorTests.cs (9)
42var watchResourceTask = Task.Run(async () => 89var watchResourceTask = Task.Run(async () => 187var watchResourceTask = Task.Run(async () => 252var watchResourceTask = Task.Run(async () => 303var watchResourceTask = Task.Run(async () => 418var watchResourceTask = Task.Run(async () => 689var watchResourceTask = Task.Run(async () => 745var watchResourceTask = Task.Run(async () => 798var watchResourceTask = Task.Run(async () =>
Orchestrator\ParameterProcessorTests.cs (1)
81var watchTask = Task.Run(async () =>
ResourceLoggerServiceTests.cs (1)
315return Task.Run(async () =>
WithUrlsTests.cs (5)
329var watchTask = Task.Run(async () => 365var watchTask = Task.Run(async () => 409var watchTask = Task.Run(async () => 498var watchTask = Task.Run(async () => 619var watchTask = Task.Run(async () =>
Aspire.RabbitMQ.Client.v7.Tests (1)
tests\Aspire.RabbitMQ.Client.Tests\ConformanceTests.cs (1)
119Task.Run(async () =>
Client.ChannelLayer.IntegrationTests (1)
DuplexChannelWithSynchronizationContext.cs (1)
266Task.Run(async () =>
ClientSample (1)
UploadSample.cs (1)
87_ = Task.Run(async () =>
dotnet (3)
Commands\Restore\RestoringCommand.cs (1)
43Task.Run(() => WorkloadManifestUpdater.BackgroundUpdateAdvertisingManifestsAsync(userProfileDir));
Commands\Test\MTP\TestApplication.cs (1)
45var testAppPipeConnectionLoop = Task.Run(async () => await WaitConnectionAsync(cancellationToken));
Commands\Test\MTP\TestApplicationActionQueue.cs (1)
27_readers[i] = Task.Run(async () => await Read(buildOptions, testOptions, output, onHelpRequested));
dotnet.Tests (1)
CommandTests\Test\IPCTests.cs (1)
22var waitTask = Task.Run(
dotnet-svcutil-lib (1)
FrameworkFork\System.ServiceModel\System\ServiceModel\Channels\MessageContent.cs (1)
184Task.Run(async () => await _messageEncoder.WriteMessageAsync(_message, bufferedStream));
HttpStress (1)
Program.cs (1)
579Task.WaitAll(Enumerable.Range(0, concurrentRequests).Select(taskNum => Task.Run(async () =>
IdeBenchmarks (2)
SQLitePersistentStorageBenchmark.cs (2)
108tasks.Add(Task.Run(async () => 115tasks.Add(Task.Run(async () =>
IdeCoreBenchmarks (2)
NavigateToBenchmarks.cs (2)
164var tasks = project.Documents.Select(d => Task.Run( 189var tasks = _workspace.CurrentSolution.Projects.SelectMany(p => p.Documents).Select(d => Task.Run(
IIS.FunctionalTests (2)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
src\Servers\IIS\IIS\test\Common.FunctionalTests\RequestResponseTests.cs (1)
744tasks.Add(Task.Run(RunRequests));
IIS.LongTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
IIS.NewHandler.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
IIS.NewShim.FunctionalTests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
IIS.ShadowCopy.Tests (1)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
IISExpress.FunctionalTests (2)
src\Servers\IIS\IIS\test\Common.FunctionalTests\Infrastructure\Helpers.cs (1)
61tasks.Add(Task.Run(RunRequests));
src\Servers\IIS\IIS\test\Common.FunctionalTests\RequestResponseTests.cs (1)
744tasks.Add(Task.Run(RunRequests));
InMemory.FunctionalTests (1)
RequestTests.cs (1)
605tasks.Add(Task.Run(async () =>
InProcessWebSite (4)
Startup.cs (4)
552var t2 = Task.Run(() => WriteManyTimesToResponseBody(ctx)); 553var t1 = Task.Run(() => ReadRequestBody(ctx)); 751var t2 = Task.Run(() => WriteResponseBodyAFewTimes(ctx)); 752var t1 = Task.Run(() => ReadRequestBody(ctx));
InteractiveHost.UnitTests (1)
StressTests.cs (1)
36_ = Task.Run(async () =>
Interop.FunctionalTests (1)
src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Components.Server.Tests (10)
Circuits\CircuitRegistryTest.cs (10)
246var disconnect = Task.Run(() => 252var connect = Task.Run(async () => 303var disconnect = Task.Run(() => 309var connect = Task.Run(async () => 356var disconnect = Task.Run(() => 362var connect = Task.Run(async () => 396var disconnect = Task.Run(() => registry.DisconnectAsync(circuitHost, oldId)); 433await Task.Run(() => tcs.Task.TimeoutAfter(TimeSpan.FromSeconds(10))); 459await Task.Run(() => tcs.Task.TimeoutAfter(TimeSpan.FromSeconds(10))); 515var pauseTask = Task.Run(() =>
Microsoft.AspNetCore.Components.Tests (1)
RendererTest.cs (1)
5905Task.Run(async () =>
Microsoft.AspNetCore.Components.WebViewE2E.Test (1)
BasicBlazorHybridTest.cs (1)
95Task.Run(async () =>
Microsoft.AspNetCore.Hosting.Tests (1)
WebHostTests.cs (1)
348var runHostAndVerifyApplicationStopped = Task.Run(async () =>
Microsoft.AspNetCore.Http.Connections.Tests (2)
HttpConnectionManagerTests.cs (2)
106connection.ApplicationTask = Task.Run(async () => 249connection.ApplicationTask = Task.Run(async () =>
Microsoft.AspNetCore.HttpLogging (1)
FileLoggerProcessor.cs (1)
103_outputTask = Task.Run(ProcessLogQueue);
Microsoft.AspNetCore.Mvc.TagHelpers.Test (12)
CacheTagHelperTest.cs (8)
592var task1 = Task.Run(async () => 599var task2 = Task.Run(async () => 675var task1 = Task.Run(async () => 682var task2 = Task.Run(async () => 874var task1 = Task.Run(() => cacheTagHelper1.ProcessAsync(GetTagHelperContext(cache.Key1), tagHelperOutput)); 875var task2 = Task.Run(() => cacheTagHelper2.ProcessAsync(GetTagHelperContext(cache.Key2), tagHelperOutput)); 919var task1 = Task.Run(() => cacheTagHelper1.ProcessAsync(GetTagHelperContext(cache.Key1), tagHelperOutput1)); 920var task2 = Task.Run(() => cacheTagHelper2.ProcessAsync(GetTagHelperContext(cache.Key2), tagHelperOutput2));
DistributedCacheTagHelperTest.cs (4)
595var task1 = Task.Run(async () => 602var task2 = Task.Run(async () => 687var task1 = Task.Run(async () => 694var task2 = Task.Run(async () =>
Microsoft.AspNetCore.Mvc.ViewFeatures.Test (2)
DefaultDisplayTemplatesTest.cs (1)
351.Returns(Task.Run(() =>
DefaultEditorTemplatesTest.cs (1)
1299.Returns(Task.Run(() =>
Microsoft.AspNetCore.OutputCaching.Tests (6)
OutputCacheMiddlewareTests.cs (6)
839var task1 = Task.Run(() => middleware.Invoke(context1.HttpContext)); 844var task2 = Task.Run(() => middleware.Invoke(context2.HttpContext)); 892var task1 = Task.Run(() => middleware.Invoke(context1.HttpContext)); 898var task2 = Task.Run(() => middleware.Invoke(context2.HttpContext)); 954var task1 = Task.Run(() => middleware.Invoke(context1.HttpContext)); 956var task2 = Task.Run(() => middleware.Invoke(context2.HttpContext));
Microsoft.AspNetCore.Server.HttpSys (1)
src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.IIS (1)
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\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Core.Tests (1)
KestrelServerTests.cs (1)
698var continuationTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Microbenchmarks (3)
NamedPipesTransportBenchmark.cs (1)
98parallelTasks[i] = Task.Run(async () =>
PipeThroughputBenchmark.cs (2)
29var writing = Task.Run(async () => 39var reading = 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\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.Server.Kestrel.Transport.Quic (1)
src\Shared\Buffers.MemoryPool\DefaultMemoryPoolFactory.cs (1)
28_timerTask = Task.Run(async () =>
Microsoft.AspNetCore.SignalR.Client.FunctionalTests (4)
HubConnectionTests.cs (1)
2932_runTask = Task.Run(Run);
Hubs.cs (3)
229Task.Run(async () => 253_ = Task.Run(async () => 277_ = Task.Run(async () =>
Microsoft.AspNetCore.SignalR.Microbenchmarks (1)
DefaultHubDispatcherBenchmark.cs (1)
162_ = Task.Run(async () =>
Microsoft.AspNetCore.SignalR.StackExchangeRedis.Tests (1)
RedisEndToEnd.cs (1)
260_ = Task.Run(async () =>
Microsoft.AspNetCore.SignalR.Tests (11)
HubConnectionHandlerTestUtils\Hubs.cs (9)
347_ = Task.Run(async () => 706_ = Task.Run(async () => 816_ = Task.Run(async () => 1037Task.Run(async () => 1052Task.Run(async () => 1067Task.Run(async () => 1082Task.Run(() => 1097Task.Run(async () => 1133Task.Run(async () =>
NativeAotTests.cs (2)
251_ = Task.Run(async () => 284_ = Task.Run(async () =>
Microsoft.AspNetCore.TestHost.Tests (1)
TestClientTests.cs (1)
486var writeTask = Task.Run(async () =>
Microsoft.Build (2)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (1)
943cleanupTasks[idx++] = Task.Run(async () =>
BackEnd\TaskExecutionHost\TaskExecutionHost.cs (1)
706Task.Run(async delegate
Microsoft.CodeAnalysis.EditorFeatures (1)
EditAndContinue\EditAndContinueLanguageService.cs (1)
58_ = Task.Run(async () =>
Microsoft.CodeAnalysis.Workspaces.MSBuild (2)
MSBuild\BuildHostProcessManager.cs (1)
184Task.Run(async () =>
Rpc\RpcClient.cs (1)
52Task.Run(async () =>
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
Rpc\RpcServer.cs (1)
79var runningTask = Task.Run(() => ProcessRequestAsync(request));
Microsoft.CodeAnalysis.Workspaces.MSBuild.UnitTests (1)
src\Workspaces\MSBuild\BuildHost\Rpc\RpcServer.cs (1)
79var runningTask = Task.Run(() => ProcessRequestAsync(request));
Microsoft.DotNet.Build.Tasks.Feed (11)
src\common\UploadToAzure.cs (1)
88uploadTasks.Add(Task.Run(async () =>
src\PublishArtifactsInManifestBase.cs (7)
790await Task.WhenAll(BuildModel.Artifacts.Pdbs.Select(pdb => Task.Run(async () => 895publishTasks.Add(Task.Run(async () => 1113publishTasks.Add(Task.Run(async () => 1266await Task.WhenAll(packagesToPublish.Select(package => Task.Run(async () => 1397await Task.WhenAll(packagesToPublish.Select(packageToPublish => Task.Run(async () => 1661await Task.WhenAll(assetsToPublish.Select(asset => Task.Run(async () => 1783Task.Run(async () => await assetPublisher.PublishAssetAsync(asset.localBlobPath, asset.id, pushOptions, clientThrottle))));
src\PublishArtifactsInManifestV4.cs (3)
197Task.Run(async () => await HandlePackagePublishingAsync(buildAssets, clientThrottle)), 198Task.Run(async () => await HandleBlobPublishingAsync(buildAssets, clientThrottle)), 199Task.Run(async () => await HandleSymbolPublishingAsync(
Microsoft.DotNet.Cli.Utils (1)
FileAccessRetrier.cs (1)
95Task.Run(() => Task.Delay(nextWaitTime)).Wait();
Microsoft.DotNet.Helix.Sdk (1)
HelixTask.cs (1)
61System.Threading.Tasks.Task.Run(() => ExecuteCore(_cancel.Token)).GetAwaiter().GetResult();
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)
111Task.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.Build.Containers.UnitTests (1)
RegistryTests.cs (1)
429_ = 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.VisualStudio.LanguageServices (2)
Diagnostics\VisualStudioDiagnosticAnalyzerProvider.WorkspaceEventListener.cs (1)
43_ = Task.Run(() => InitializeWorkspaceAsync(setter)).CompletesAsyncOperation(token);
ProjectSystem\Legacy\SolutionEventsBatchScopeCreator.cs (1)
101batchScopeTasks = _fullSolutionLoadScopes.SelectAsArray(static s => Task.Run(() => s.batchScope.DisposeAsync().AsTask()));
Microsoft.VisualStudio.LanguageServices.CodeLens (1)
ReferenceCodeLensProvider.cs (1)
137_pollingTask ??= Task.Run(PollForUpdatesAsync).ReportNonFatalErrorAsync();
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (1)
PersistentStorage\AbstractPersistentStorageTests.cs (1)
915Task.Run(async () =>
ScenarioTests.Common.Tests (3)
ScenarioTestTypes.cs (3)
973Task.Run(async () => 984Task.Run(async () => 995Task.Run(async () =>
SignalRSamples (2)
Hubs\Streaming.cs (1)
34Task.Run(async () =>
Hubs\UploadHub.cs (1)
67_ = Task.Run(async () =>
Sockets.FunctionalTests (1)
src\Servers\Kestrel\test\FunctionalTests\ResponseTests.cs (1)
821var sendTask = Task.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 () =>
System.Windows.Forms.Tests (6)
System\Windows\Forms\ControlTests_InvokeAsync.cs (5)
29await Task.Run(async () => 71await Task.Run(async () => 108await Task.Run(async () => 151await Task.Run(async () => 195await Task.Run(async () =>
System\Windows\Forms\FormTests.cs (1)
2666Task closerTask = Task.Run(async () =>
System.Windows.Forms.UI.IntegrationTests (2)
DataGridViewTests.cs (1)
64_ = Task.Run(async () =>
ListControlUnboundActionListTests.cs (1)
21var disposeTask = Task.Run(async () =>
TestProject.AppHost (1)
Program.cs (1)
8_ = Task.Run(async () =>
VBCSCompiler (1)
src\Compilers\Server\VBCSCompiler\NamedPipeClientConnectionHost.cs (1)
73var task = Task.Run(() => ListenCoreAsync(PipeName, Logger, _queue, _cancellationTokenSource.Token));
VBCSCompiler.UnitTests (1)
CompilerServerTests.cs (1)
293async () => await Task.Run(async () =>
WebSocketSample (1)
Program.cs (1)
32var sending = Task.Run(async () =>
xunit.assert (1)
Sdk\AssertHelper.cs (1)
759 Task.Run(valueTask.AsTask).GetAwaiter().GetResult();