Run

209 references to Run

aspire (3)

Backchannel\AuxiliaryBackchannelMonitor.cs (1)

274_ = Task.Run(async () => await DisconnectAsync(conn).ConfigureAwait(false));

Interaction\ExtensionInteractionService.cs (1)

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

Utils\ConsoleActivityLogger.cs (1)

107_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)

293_resourceSubscriptionTask = Task.Run(async () =>

DashboardWebApplication.cs (1)

414_ = 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)

307var completionTask = Task.Run(async () =>

Dcp\DcpExecutor.cs (8)

307var watchResourcesTask = Task.Run(async () => 312Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, Model.Dcp.ExecutableKind, (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 313Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, Model.Dcp.ContainerKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 314Task.Run(() => WatchKubernetesResourceAsync<ContainerExec>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainerExecsMap, Model.Dcp.ContainerExecKind, (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 315Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 316Task.Run(() => WatchKubernetesResourceAsync<Endpoint>(ProcessEndpointChange))).ConfigureAwait(false); 322var watchSubscribersTask = Task.Run(async () => 334var watchInformationChannelTask = Task.Run(async () =>

Dcp\DcpHost.cs (2)

153_logProcessorTask = Task.Run(() => StartLoggingSocketAsync(loggingSocket)); 272outputLoggers.Add(Task.Run(() => LogSocketOutputAsync(acceptedSocket, _shutdownCts.Token)));

Orchestrator\ParameterProcessor.cs (1)

52var parameterResolutionTask = Task.Run(async () =>

Pipelines\DistributedApplicationPipeline.cs (1)

700allStepTasks[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)

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

Aspire.Hosting.Azure.Tests (1)

AzureDeployerTests.cs (1)

1543var runTask = Task.Run(() => app.RunAsync(cts.Token));

Aspire.Hosting.Testing.Tests (1)

ResourceLoggerForwarderServiceTests.cs (1)

61var subscriberLoop = Task.Run(async () =>

Aspire.Hosting.Tests (23)

Dashboard\DashboardResourceTests.cs (1)

543var watchForLogSubs = Task.Run(async () =>

Dashboard\ResourcePublisherTests.cs (2)

37var task = Task.Run(async () => 162var task = Task.Run(async () =>

Dcp\DcpExecutorTests.cs (1)

96var 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)

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 () => 430var watchResourceTask = Task.Run(async () => 710var watchResourceTask = Task.Run(async () => 767var watchResourceTask = Task.Run(async () => 821var watchResourceTask = Task.Run(async () =>

Orchestrator\ParameterProcessorTests.cs (1)

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

Pipelines\PipelineLoggerProviderTests.cs (2)

93var task1 = Task.Run(async () => 101var task2 = Task.Run(async () =>

Publishing\DeploymentStateManagerTests.cs (1)

115tasks.Add(Task.Run(async () =>

ResourceLoggerServiceTests.cs (1)

315return Task.Run(async () =>

WithUrlsTests.cs (2)

477var watchTask = Task.Run(async () => 595var watchTask = Task.Run(async () =>

Aspire.RabbitMQ.Client.Tests (1)

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-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.CodeAnalysis.EditorFeatures (1)

EditAndContinue\EditAndContinueLanguageService.cs (1)

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

Microsoft.CodeAnalysis.Workspaces.MSBuild (2)

MSBuild\BuildHostProcessManager.cs (1)

191Task.Run(async () =>

Rpc\RpcClient.cs (1)

51Task.Run(async () =>

Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)

Rpc\RpcServer.cs (1)

78var runningTask = Task.Run(() => ProcessRequestAsync(request));

Microsoft.CodeAnalysis.Workspaces.MSBuild.UnitTests (1)

src\Workspaces\MSBuild\BuildHost\Rpc\RpcServer.cs (1)

78var 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.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.VisualStudio.Extensibility.Testing.Xunit (1)

src\VisualStudio\IntegrationTest\Harness\XUnitShared\Harness\VisualStudioInstanceFactory.cs (1)

463_ = Task.Run(() => TakeScreenShotEveryTimeIntervalAsync(dir, commandBeingExecuted, cancellatokenSource.Token));

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)

260async () => 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();