173 references to Run
aspire (1)
Interaction\ExtensionInteractionService.cs (1)
33_ = Task.Run(async () =>
Aspire.Dashboard (10)
Components\Controls\Chart\ChartContainer.razor.cs (1)
71_tickTask = Task.Run(UpdateDataAsync);
Components\Interactions\InteractionsProvider.cs (2)
70_dialogDisplayTask = Task.Run(async () => 82_watchInteractionsTask = Task.Run(async () =>
Components\Pages\ConsoleLogs.razor.cs (2)
216_resourceSubscriptionTask = Task.Run(async () => 493var consoleLogsTask = Task.Run(async () =>
Components\Pages\Resources.razor.cs (1)
253_resourceSubscriptionTask = Task.Run(async () =>
DashboardWebApplication.cs (1)
357_ = Task.Run(async () =>
Model\ResourceOutgoingPeerResolver.cs (1)
28_watchTask = Task.Run(async () =>
Telemetry\DashboardTelemetrySender.cs (1)
45_sendLoopTask = Task.Run(async () =>
Utils\CallbackThrottler.cs (1)
101_ = 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 (12)
ApplicationModel\ResourceLoggerService.cs (1)
306var completionTask = Task.Run(async () =>
Dcp\DcpExecutor.cs (7)
224var watchResourcesTask = Task.Run(async () => 229Task.Run(() => WatchKubernetesResourceAsync<Executable>((t, r) => ProcessResourceChange(t, r, _resourceState.ExecutablesMap, "Executable", (e, s) => _snapshotBuilder.ToSnapshot(e, s)))), 230Task.Run(() => WatchKubernetesResourceAsync<Container>((t, r) => ProcessResourceChange(t, r, _resourceState.ContainersMap, "Container", (c, s) => _snapshotBuilder.ToSnapshot(c, s)))), 231Task.Run(() => WatchKubernetesResourceAsync<Service>(ProcessServiceChange)), 232Task.Run(() => WatchKubernetesResourceAsync<Endpoint>(ProcessEndpointChange))).ConfigureAwait(false); 238var watchSubscribersTask = Task.Run(async () => 250var watchInformationChannelTask = Task.Run(async () =>
Dcp\DcpHost.cs (2)
149_logProcessorTask = Task.Run(() => StartLoggingSocketAsync(loggingSocket)); 249outputLoggers.Add(Task.Run(() => LogSocketOutputAsync(acceptedSocket, _shutdownCts.Token)));
Orchestrator\ParameterProcessor.cs (1)
44_ = Task.Run(async () =>
Publishing\PublishingActivityProgressReporter.cs (1)
25_interactionServiceSubscriber = Task.Run(() => SubscribeToInteractionsAsync(_cancellationTokenSource.Token));
Aspire.Hosting.Testing.Tests (1)
ResourceLoggerForwarderServiceTests.cs (1)
61var subscriberLoop = Task.Run(async () =>
Aspire.Hosting.Tests (17)
Dashboard\DashboardResourceTests.cs (1)
458var watchForLogSubs = Task.Run(async () =>
Dashboard\ResourcePublisherTests.cs (2)
38var task = Task.Run(async () => 163var task = Task.Run(async () =>
Dcp\DcpExecutorTests.cs (1)
92var watchResourceTask = Task.Run(async () =>
InteractionServiceTests.cs (1)
123var readTask = Task.Run(async () =>
Orchestrator\ApplicationOrchestratorTests.cs (6)
38var watchResourceTask = Task.Run(async () => 85var watchResourceTask = Task.Run(async () => 183var watchResourceTask = Task.Run(async () => 248var watchResourceTask = Task.Run(async () => 299var watchResourceTask = Task.Run(async () => 414var watchResourceTask = Task.Run(async () =>
Orchestrator\ParameterProcessorTests.cs (1)
75var watchTask = Task.Run(async () =>
ResourceLoggerServiceTests.cs (1)
316return Task.Run(async () =>
WithUrlsTests.cs (4)
330var watchTask = Task.Run(async () => 366var watchTask = Task.Run(async () => 453var watchTask = Task.Run(async () => 574var 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-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 () =>
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)
745tasks.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)
745tasks.Add(Task.Run(RunRequests));
InMemory.FunctionalTests (1)
RequestTests.cs (1)
605tasks.Add(Task.Run(async () =>
InProcessWebSite (4)
src\Servers\IIS\IIS\test\testassets\InProcessWebSite\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)
5842Task.Run(async () =>
Microsoft.AspNetCore.Components.WebViewE2E.Test (1)
BasicBlazorHybridTest.cs (1)
95Task.Run(async () =>
Microsoft.AspNetCore.Hosting.Tests (1)
WebHostTests.cs (1)
346var 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)
382var writeTask = Task.Run(async () =>
Microsoft.Build (2)
BackEnd\Components\ProjectCache\ProjectCacheService.cs (1)
943cleanupTasks[idx++] = Task.Run(async () =>
BackEnd\TaskExecutionHost\TaskExecutionHost.cs (1)
681Task.Run(async delegate
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
Rpc\RpcServer.cs (1)
79var runningTask = Task.Run(() => ProcessRequestAsync(request));
Microsoft.DotNet.Build.Tasks.Feed (1)
src\common\UploadToAzure.cs (1)
88uploadTasks.Add(Task.Run(async () =>
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)
254tasks[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.LanguageServices (1)
Diagnostics\VisualStudioDiagnosticAnalyzerProvider.WorkspaceEventListener.cs (1)
43_ = Task.Run(() => InitializeWorkspaceAsync(setter)).CompletesAsyncOperation(token);
Microsoft.VisualStudio.LanguageServices.CodeLens (1)
ReferenceCodeLensProvider.cs (1)
137_pollingTask ??= Task.Run(PollForUpdatesAsync).ReportNonFatalErrorAsync();
Microsoft.VisualStudio.LanguageServices.CSharp.UnitTests (1)
PersistentStorage\AbstractPersistentStorageTests.cs (1)
918Task.Run(async () =>
ScenarioTests.Common.Tests (3)
ScenarioTestTypes.cs (3)
973Task.Run(async () => 984Task.Run(async () => 995Task.Run(async () =>
Shared.Tests (4)
Pools\PoolTests.cs (4)
245Task.Run(() => FunWithPools(pool, 1)), 246Task.Run(() => FunWithPools(pool, 2)), 247Task.Run(() => FunWithPools(pool, 3)), 248Task.Run(() => FunWithPools(pool, 4))
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)
30Task.Run(async () =>
System.Windows.Forms (1)
System\Windows\Forms\Controls\PictureBox\PictureBox.cs (1)
482Task.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 () =>
WebSocketSample (1)
Program.cs (1)
32var sending = Task.Run(async () =>
xunit.assert (1)
Sdk\AssertHelper.cs (1)
735 Task.Run(valueTask.AsTask).GetAwaiter().GetResult();