5 types derived from TaskScheduler
Microsoft.Build (2)
BackEnd\Components\RequestBuilder\RequestBuilder.cs (1)
1580private sealed class DedicatedThreadsTaskScheduler : TaskScheduler
Utilities\AwaitExtensions.cs (1)
153private class OneSTAThreadPerTaskScheduler : TaskScheduler
System.Private.CoreLib (3)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (1)
507private sealed class ConcurrentExclusiveTaskScheduler : TaskScheduler
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (1)
536internal sealed class SynchronizationContextTaskScheduler : TaskScheduler
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ThreadPoolTaskScheduler.cs (1)
22internal sealed class ThreadPoolTaskScheduler : TaskScheduler
738 references to TaskScheduler
Aspire.Hosting (3)
Backchannel\AuxiliaryBackchannelRpcTarget.cs (1)
736_ = Task.WhenAll(tasks).ContinueWith(_ => channel.Writer.Complete(), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Dcp\Process\ProcessUtil.cs (1)
122}, TaskScheduler.Default);
IInteractionService.cs (1)
154}, TaskScheduler.Default);
Aspire.Hosting.Azure (1)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)
122}, TaskScheduler.Default);
Aspire.Hosting.DevTunnels (1)
src\Shared\CoalescingAsyncOperation.cs (1)
51}, this, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
Aspire.Hosting.Docker (1)
src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)
122}, TaskScheduler.Default);
Binding.WS.TransportWithMessageCredentialSecurity.IntegrationTests (1)
WSNetTcpTransportWithMessageCredentialSecurityTests.cs (1)
125Task.Factory.StartNew(() => NetTcp_SecModeTransWithMessCred_UserNameClientCredential_Succeeds(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
Client.ChannelLayer.IntegrationTests (2)
DuplexChannelWithSynchronizationContext.cs (2)
155Task.Factory.StartNew(() => SingleThreadedSyncContext_CallbackUsingDefaultSyncCtx_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 220Task.Factory.StartNew(() => SingleThreadedSyncContext_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
Client.TypedClient.IntegrationTests (5)
TypedProxyTests.4.0.0.cs (3)
72Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 106Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 160Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_Synchronous_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
TypedProxyTests.4.1.0.cs (2)
26Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncBeginEnd_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 40Task.Factory.StartNew(() => TypedProxyTests.ServiceContract_TypedProxy_NetTcpBinding_AsyncTask_Call(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
CodeStyleConfigFileGenerator (2)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
Consumer (1)
ConsumerWorker.cs (1)
39}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Contract.Service.IntegrationTests (8)
ServiceContractTests.4.0.0.cs (4)
336Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 389Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 440Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 490Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
ServiceContractTests.4.1.0.cs (4)
210Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 224Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_DefaultSettings_Echo_RoundTrips_String_Streamed_Async(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 614Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 628Task.Factory.StartNew(() => ServiceContractTests.NetTcp_NoSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
dotnet-svcutil-lib (9)
FrameworkFork\System.ServiceModel\Internals\System\Runtime\ActionItem.cs (2)
37Task.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 67Task.Factory.StartNew(callback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
FrameworkFork\System.ServiceModel\Internals\System\Runtime\TaskHelpers.cs (6)
47}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 68}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 92}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 124}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 281return (TaskScheduler.Current == TaskScheduler.Default) &&
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1183Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
GenerateDocumentationAndConfigFiles (4)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Microsoft.AspNetCore.Components.WebAssembly (2)
Rendering\WebAssemblyDispatcher.cs (2)
112}, TaskScheduler.FromCurrentSynchronizationContext()); 156}, TaskScheduler.FromCurrentSynchronizationContext());
Microsoft.AspNetCore.DataProtection (2)
KeyManagement\KeyRingProvider.cs (2)
453TaskScheduler.Default); 520TaskScheduler.Default);
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)
RedisOutputCacheStore.cs (1)
88_ = Task.Factory.StartNew(RunGarbageCollectionLoopAsync, default, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Microsoft.AspNetCore.Owin (1)
WebSockets\OwinWebSocketAcceptAdapter.cs (1)
129adapter.UpstreamTask.ContinueWith(adapter.EnsureCompleted, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
Microsoft.AspNetCore.SignalR.Client.Core (1)
HubConnection.cs (1)
903TaskScheduler.Default);
Microsoft.AspNetCore.SpaServices.Extensions (1)
Util\EventedStreamReader.cs (1)
30Task.Factory.StartNew(Run, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.AspNetCore.TestHost (1)
HttpContextBuilder.cs (1)
157_ = Task.Factory.StartNew(RunRequestAsync, default, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Build (6)
BackEnd\BuildManager\BuildManager.cs (1)
1799TaskScheduler.Default);
BackEnd\Components\RequestBuilder\RequestBuilder.cs (2)
42private static readonly TaskScheduler s_dedicatedScheduler = new DedicatedThreadsTaskScheduler(); 681TaskScheduler.Default).Unwrap();
Logging\BinaryLogger\ProjectImportsCollector.cs (1)
130TaskScheduler.Default);
Utilities\AwaitExtensions.cs (2)
27private static TaskScheduler s_staScheduler; 32internal static TaskScheduler OneSTAThreadPerTaskSchedulerInstance
Microsoft.Build.Framework (2)
src\msbuild\artifacts\.packages\microsoft.codeanalysis.contracts\5.0.0-1.25277.114\contentFiles\cs\net9.0\ErrorReporting\FatalError.cs (2)
234TaskScheduler.Default); 244TaskScheduler.Default);
Microsoft.Build.Tasks.CodeAnalysis (2)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
Microsoft.CodeAnalysis (2)
DiagnosticAnalyzer\AnalyzerDriver.cs (1)
688.ContinueWith(c => DiagnosticQueue.TryComplete(), cancellationToken, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
DiagnosticAnalyzer\AsyncQueue.cs (1)
326TaskScheduler.Default);
Microsoft.CodeAnalysis.Analyzers (18)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (14)
44return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 62return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 109private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 222return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 240return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 274private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 396/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 397private readonly TaskScheduler _scheduler; 418protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 585int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 611int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 638bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.AnalyzerUtilities (18)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (14)
44return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 62return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 109private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 222return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 240return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 274private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 396/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 397private readonly TaskScheduler _scheduler; 418protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 585int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 611int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 638bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.CodeStyle (18)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (14)
44return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 62return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 109private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 222return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 240return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 274private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 396/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 397private readonly TaskScheduler _scheduler; 418protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 585int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 611int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 638bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.Extensions.Package (2)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
Microsoft.CodeAnalysis.Features (2)
ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingSemanticChangeProcessor.cs (2)
64TaskScheduler.Default); 354TaskScheduler.Default);
Microsoft.CodeAnalysis.ResxSourceGenerator (18)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (14)
44return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 62return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 109private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 222return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 240return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 274private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 396/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 397private readonly TaskScheduler _scheduler; 418protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 585int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 611int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 638bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Microsoft.CodeAnalysis.Workspaces (15)
FindSymbols\FindReferences\FindReferencesSearchEngine.cs (2)
34private static readonly TaskScheduler s_exclusiveScheduler = new ConcurrentExclusiveSchedulerPair().ExclusiveScheduler; 57TaskScheduler = _options.Explicit ? TaskScheduler.Default : s_exclusiveScheduler,
FindSymbols\SymbolTree\SymbolTreeInfoCacheService.cs (3)
28private static readonly TaskScheduler s_exclusiveScheduler = new ConcurrentExclusiveSchedulerPair().ExclusiveScheduler; 40private readonly TaskScheduler _scheduler; 51_scheduler = workspace.Kind == WorkspaceKind.RemoteWorkspace ? TaskScheduler.Default : s_exclusiveScheduler;
Shared\TestHooks\AsynchronousOperationListener.cs (1)
87TaskScheduler.Default).Unwrap();
Shared\TestHooks\AsynchronousOperationListenerProvider+NullOperationListener.cs (1)
54TaskScheduler.Default);
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
Workspace\Host\TaskScheduler\ITaskSchedulerProvider.cs (1)
14TaskScheduler CurrentContextScheduler { get; }
Workspace\Host\TaskScheduler\TaskSchedulerProvider.cs (3)
23public TaskScheduler CurrentContextScheduler 24=> (SynchronizationContext.Current != null) ? TaskScheduler.FromCurrentSynchronizationContext() : TaskScheduler.Default;
Microsoft.CodeAnalysis.Workspaces.MSBuild.BuildHost (1)
Rpc\RpcServer.cs (1)
117TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
Microsoft.CodeAnalysis.Workspaces.MSBuild.Contracts (2)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
Microsoft.Extensions.Caching.Memory (3)
CacheEntry.CacheEntryTokens.cs (1)
110CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
CacheEntry.cs (1)
286}, obj, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
MemoryCache.cs (1)
436CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.DependencyInjection (1)
ServiceLookup\StackGuard.cs (1)
57Task<R> task = Task.Factory.StartNew((Func<object?, R>)action, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.FileProviders.Physical (1)
PhysicalFilesWatcher.cs (1)
831TaskScheduler.Default);
Microsoft.JSInterop (3)
Infrastructure\DotNetDispatcher.cs (3)
118task.ContinueWith(t => EndInvokeDotNetAfterTask(t, jsRuntime, invocationInfo), TaskScheduler.Current); 123valueTaskResult.AsTask().ContinueWith(t => EndInvokeDotNetAfterTask(t, jsRuntime, invocationInfo), TaskScheduler.Current); 131innerTask!.ContinueWith(t => EndInvokeDotNetAfterTask(t, jsRuntime, invocationInfo), TaskScheduler.Current);
Microsoft.Maui.Controls (2)
Internals\AsyncValue.cs (2)
48 TaskScheduler scheduler = TaskScheduler.FromCurrentSynchronizationContext();
Microsoft.Maui.Graphics.Win2D.WinUI.Desktop (2)
src\Graphics\src\Graphics\Platforms\Windows\AsyncPump.cs (2)
44 { syncCtx.Complete(); }, TaskScheduler.Default); 75 { syncCtx.Complete(); }, TaskScheduler.Default);
Microsoft.Maui.Resizetizer (1)
AsyncTaskExtensions.cs (1)
34 TaskScheduler = TaskScheduler.Default,
Microsoft.ML.Core (1)
Utilities\ResourceManagerUtils.cs (1)
163var timeoutTask = Task.Delay(timeout).ContinueWith(task => default(Exception), TaskScheduler.Default);
Microsoft.TemplateEngine.Utils (2)
AsyncLazy.cs (2)
21: base(() => Task.Factory.StartNew(valueFactory, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default)) 30() => taskFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default)
MSBuild.Coordinator (1)
CoordinatorServer.cs (1)
96_ = clientTask.ContinueWith(_ => clientTasks.TryRemove(clientTask, out byte _), TaskScheduler.Default);
mscorlib (1)
src\runtime\src\libraries\shims\mscorlib\ref\mscorlib.cs (1)
1168[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]
netstandard (1)
netstandard.cs (1)
2127[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]
NuGet.Commands (1)
src\nuget-client\build\Shared\TaskResultCache.cs (1)
115TaskScheduler.Default);
NuGet.DependencyResolver.Core (1)
src\nuget-client\build\Shared\TaskResultCache.cs (1)
115TaskScheduler.Default);
NuGet.Protocol (4)
LocalRepositories\LocalPackageSearchResource.cs (1)
87}, token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
Plugins\StandardInputReceiver.cs (1)
107TaskScheduler.Default);
src\nuget-client\build\Shared\TaskResultCache.cs (1)
115TaskScheduler.Default);
Utility\DedicatedAsynchronousProcessingThread.cs (1)
43TaskScheduler.Default);
OrderProcessor (1)
OrderProcessingWorker.cs (1)
43}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);
Roslyn.Diagnostics.Analyzers (18)
src\roslyn\src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)
237TaskScheduler.Default); 247TaskScheduler.Default);
src\roslyn\src\Dependencies\Threading\ParallelExtensions.NetFramework.cs (14)
44return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 62return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 87private static TaskScheduler EffectiveTaskScheduler(ParallelOptions options) => options.TaskScheduler ?? TaskScheduler.Current; 109private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 222return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 240return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 274private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 396/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 397private readonly TaskScheduler _scheduler; 418protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 585int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 611int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 638bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)
435TaskScheduler.Default);
src\roslyn\src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)
76channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
ScenarioTests.Common.Tests (1)
ScenarioTestTypes.cs (1)
278t.ContinueWith(delegate { syncCtx.Complete(); }, TaskScheduler.Default);
Security.TransportSecurity.IntegrationTests (2)
Tcp\StreamingTests.4.1.0.cs (2)
385Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 403Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_Async_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
System.ComponentModel.EventBasedAsync (1)
System\ComponentModel\BackgroundWorker.cs (1)
133TaskScheduler.Default
System.Data.Odbc (2)
Common\System\Data\ProviderBase\DbConnectionFactory.cs (2)
89}, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default)!; 125}, TaskScheduler.Default);
System.Data.OleDb (2)
System\Data\ProviderBase\DbConnectionFactory.cs (2)
205}, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default)!; 245}, TaskScheduler.Default);
System.IO.Pipes (1)
System\IO\Pipes\NamedPipeClientStream.cs (1)
202}, (this, timeout, cancellationToken, startTime), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
686TaskScheduler.Default);
System.Linq.Expressions (1)
System\Linq\Expressions\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew(action!, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Linq.Parallel (25)
System\Linq\Parallel\Merging\DefaultMergeHelper.cs (2)
33private readonly TaskScheduler _taskScheduler; // The task manager to execute the query. 46TaskScheduler taskScheduler, CancellationState cancellationState, int queryId)
System\Linq\Parallel\Merging\MergeExecutor.cs (1)
50PartitionedStream<TInputOutput, TKey> partitions, bool ignoreOutput, ParallelMergeOptions options, TaskScheduler taskScheduler, bool isOrdered,
System\Linq\Parallel\Merging\OrderPreservingMergeHelper.cs (2)
28private readonly TaskScheduler _taskScheduler; // The task manager to execute the query. 38internal OrderPreservingMergeHelper(PartitionedStream<TInputOutput, TKey> partitions, TaskScheduler taskScheduler,
System\Linq\Parallel\Merging\OrderPreservingPipeliningMergeHelper.cs (2)
46private readonly TaskScheduler _taskScheduler; // The task manager to execute the query. 116TaskScheduler taskScheduler,
System\Linq\Parallel\QueryOperators\PartitionedStreamMerger.cs (2)
24private readonly TaskScheduler _taskScheduler; 44internal PartitionedStreamMerger(bool forEffectMerge, ParallelMergeOptions mergeOptions, TaskScheduler taskScheduler, bool outputOrdered,
System\Linq\Parallel\QueryOperators\QueryOperator.cs (1)
286TaskScheduler? taskScheduler = settings.TaskScheduler;
System\Linq\Parallel\QueryOperators\QuerySettings.cs (5)
27private TaskScheduler? _taskScheduler; 45internal TaskScheduler? TaskScheduler 82internal QuerySettings(TaskScheduler? taskScheduler, int? degreeOfParallelism, 126TaskScheduler? tm = this.TaskScheduler ?? settings2.TaskScheduler; 176settings.TaskScheduler ??= TaskScheduler.Default;
System\Linq\Parallel\Scheduling\OrderPreservingPipeliningSpoolingTask.cs (1)
151TaskScheduler taskScheduler, bool autoBuffered)
System\Linq\Parallel\Scheduling\OrderPreservingSpoolingTask.cs (1)
72Shared<TInputOutput[]?> results, TaskScheduler taskScheduler)
System\Linq\Parallel\Scheduling\QueryTask.cs (4)
60internal Task RunSynchronously(TaskScheduler taskScheduler) 62Debug.Assert(taskScheduler == TaskScheduler.Default, "PLINQ queries can currently execute only on the default scheduler."); 79internal Task RunAsynchronously(TaskScheduler taskScheduler) 81Debug.Assert(taskScheduler == TaskScheduler.Default, "PLINQ queries can currently execute only on the default scheduler.");
System\Linq\Parallel\Scheduling\SpoolingTask.cs (3)
34SynchronousChannel<TInputOutput>[] channels, TaskScheduler taskScheduler) 90AsynchronousChannel<TInputOutput>[] channels, TaskScheduler taskScheduler) 134QueryTaskGroupState groupState, PartitionedStream<TInputOutput, TIgnoreKey> partitions, TaskScheduler taskScheduler)
System\Linq\Parallel\Utils\PLINQETWProvider.cs (1)
34private static readonly int s_defaultSchedulerId = TaskScheduler.Default.Id;
System.Net.Http (7)
System\Net\Http\MessageProcessingHandler.cs (1)
103}, tcs, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
1146CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (2)
878}, altSvcBlocklistTimerCt, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 887}, altSvcBlocklistTimerCt, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)
176}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 501}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Current);
System\Net\Http\SocketsHttpHandler\HttpConnectionBase.cs (1)
325CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
System.Net.Http.WinHttpHandler (2)
System\Net\Http\NoWriteNoSeekStreamContent.cs (1)
59}, _content, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
System\Net\Http\WinHttpHandler.cs (1)
653TaskScheduler.Default);
System.Net.HttpListener (1)
src\runtime\src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
358TaskScheduler.Default);
System.Net.NameResolution (3)
System\Net\Dns.cs (3)
143}, hostNameOrAddress, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 973}, key, cancellationToken, TaskContinuationOptions.DenyChildAttach, TaskScheduler.Default); 987}, key, CancellationToken.None, TaskContinuationOptions.OnlyOnCanceled | TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
System.Net.NetworkInformation (1)
System\Net\NetworkInformation\UnixIPGlobalProperties.cs (1)
57CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Ping (1)
System\Net\NetworkInformation\Ping.cs (1)
530}, AsyncOperationManager.CreateOperation(userToken), CancellationToken.None, TaskContinuationOptions.DenyChildAttach, TaskScheduler.Default);
System.Net.Quic (1)
System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)
328}, handle, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
System.Net.Requests (6)
src\runtime\src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
358TaskScheduler.Default);
System\Net\FileWebRequest.cs (4)
161this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 174}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 222this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 235}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\Net\TaskExtensions.cs (1)
37}, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
System.Net.WebSockets (1)
System\Net\WebSockets\ManagedWebSocket.cs (1)
1904TaskScheduler.Default);
System.Private.CoreLib (331)
src\runtime\src\coreclr\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.CoreCLR.cs (20)
1213TaskScheduler? sched = TaskScheduler.InternalCurrent; 1214if (sched == null || sched == TaskScheduler.Default) 1255Debug.Assert(continuationContext is TaskScheduler { }); 1256TaskScheduler sched = (TaskScheduler)continuationContext; 1463TaskScheduler? sched = TaskScheduler.InternalCurrent; 1464if (sched != null && sched != TaskScheduler.Default) 1484TaskScheduler? sched = TaskScheduler.InternalCurrent; 1485if (sched != null && sched != TaskScheduler.Default) 1529TaskScheduler? sched = TaskScheduler.InternalCurrent; 1530if (sched is null || sched == TaskScheduler.Default) 1546Debug.Assert(continuationContext is TaskScheduler); 1547if (continuationContext == TaskScheduler.InternalCurrent) 1718TaskScheduler? sched = TaskScheduler.InternalCurrent; 1719if (sched != null && sched != TaskScheduler.Default)
src\runtime\src\coreclr\System.Private.CoreLib\src\System\Runtime\CompilerServices\AsyncHelpers.RuntimeAsyncYielder.cs (3)
40TaskScheduler scheduler = TaskScheduler.Current; 41if (scheduler == TaskScheduler.Default)
src\runtime\src\coreclr\System.Private.CoreLib\src\System\Runtime\CompilerServices\RuntimeAsyncTaskContinuation.cs (6)
54TaskScheduler? sched = TaskScheduler.InternalCurrent; 55if (sched == null || sched == TaskScheduler.Default) 95Debug.Assert(continuationContext is TaskScheduler { }); 96TaskScheduler sched = (TaskScheduler)continuationContext;
src\runtime\src\libraries\System.Private.CoreLib\src\System\Diagnostics\Tracing\EventPipeEventDispatcher.Threads.cs (1)
18m_dispatchTask = Task.Factory.StartNew(() => DispatchEventsToEventListeners(sessionID, syncTimeUtc, syncTimeQPC, timeQPCFrequency, previousDispatchTask, m_dispatchTaskCancellationSource.Token), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default);
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (3)
194cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 570}, readWriteTask, default, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 582readWriteTask.m_taskScheduler = TaskScheduler.Default;
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\TextReader.cs (4)
223cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 281}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 288}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default)); 311}, new TupleSlim<TextReader, Memory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default));
src\runtime\src\libraries\System.Private.CoreLib\src\System\IO\TextWriter.cs (11)
593}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 611}, new TupleSlim<TextWriter, char, char>(this, valueChars[0], valueChars[1]), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 622}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 670}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 680}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 687}, new TupleSlim<TextWriter, char>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 705}, new TupleSlim<TextWriter, char, char>(this, valueChars[0], valueChars[1]), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 716}, new TupleSlim<TextWriter, string?>(this, value), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 765}, new TupleSlim<TextWriter, char[], int, int>(this, buffer, index, count), CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 775}, new TupleSlim<TextWriter, ReadOnlyMemory<char>>(this, buffer), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 793CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\TaskAwaiter.cs (5)
214bool customTaskScheduler = TaskScheduler.InternalCurrent is TaskScheduler scheduler && scheduler != TaskScheduler.Default; 263currentTaskAtBegin != null ? currentTaskAtBegin.m_taskScheduler!.Id : TaskScheduler.Default.Id, 290currentTaskAtEnd != null ? currentTaskAtEnd.m_taskScheduler!.Id : TaskScheduler.Default.Id,
src\runtime\src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (6)
96TaskScheduler scheduler = TaskScheduler.Current; 97if (scheduler == TaskScheduler.Default) 145TaskScheduler scheduler = TaskScheduler.Current; 146if (scheduler == TaskScheduler.Default)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)
347}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (9)
37private readonly TaskScheduler m_underlyingTaskScheduler; 73this(TaskScheduler.Default, DefaultMaxConcurrencyLevel, DEFAULT_MAXITEMSPERTASK) 80public ConcurrentExclusiveSchedulerPair(TaskScheduler taskScheduler) : 89public ConcurrentExclusiveSchedulerPair(TaskScheduler taskScheduler, int maxConcurrencyLevel) : 100public ConcurrentExclusiveSchedulerPair(TaskScheduler taskScheduler, int maxConcurrencyLevel, int maxItemsPerTask) 248public TaskScheduler ConcurrentScheduler => m_concurrentTaskScheduler; 253public TaskScheduler ExclusiveScheduler => m_exclusiveTaskScheduler; 348if (TaskScheduler.Default == m_underlyingTaskScheduler) 707public TaskScheduler TargetScheduler => m_pair.m_underlyingTaskScheduler;
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConfigureAwaitOptions.cs (1)
19/// <see cref="TaskScheduler"/> present on the originating thread at the time of the await.
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (10)
161TaskScheduler ts = TaskScheduler.Current; 162if (ts != TaskScheduler.Default) 261Debug.Assert(context is TaskScheduler or SynchronizationContext, $"context is {context}"); 276Debug.Assert(scheduler is SynchronizationContext or TaskScheduler, $"{nameof(scheduler)} is {scheduler}"); 297context is SynchronizationContext or TaskScheduler or CapturedSchedulerAndExecutionContext, 306case TaskScheduler ts: 318Debug.Assert(cc._scheduler is TaskScheduler, $"{nameof(cc._scheduler)} is {cc._scheduler}"); 319ScheduleTaskScheduler((TaskScheduler)cc._scheduler, continuation, state); 327static void ScheduleTaskScheduler(TaskScheduler scheduler, Action<object?> continuation, object? state) =>
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task_T.cs (36)
285TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 301TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) : 309TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 329TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler scheduler) 629return ContinueWith(continuationAction, TaskScheduler.Current, default, TaskContinuationOptions.None); 652return ContinueWith(continuationAction, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 664/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 678public Task ContinueWith(Action<Task<TResult>> continuationAction, TaskScheduler scheduler) 713return ContinueWith(continuationAction, TaskScheduler.Current, default, continuationOptions); 732/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 752TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 758internal Task ContinueWith(Action<Task<TResult>> continuationAction, TaskScheduler scheduler, CancellationToken cancellationToken, 810return ContinueWith(continuationAction, state, TaskScheduler.Current, default, TaskContinuationOptions.None); 834return ContinueWith(continuationAction, state, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 847/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 861public Task ContinueWith(Action<Task<TResult>, object?> continuationAction, object? state, TaskScheduler scheduler) 897return ContinueWith(continuationAction, state, TaskScheduler.Current, default, continuationOptions); 917/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 937TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 943internal Task ContinueWith(Action<Task<TResult>, object?> continuationAction, object? state, TaskScheduler scheduler, CancellationToken cancellationToken, 998return ContinueWith(continuationFunction, TaskScheduler.Current, default, TaskContinuationOptions.None); 1027return ContinueWith(continuationFunction, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 1041/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 1055public Task<TNewResult> ContinueWith<TNewResult>(Func<Task<TResult>, TNewResult> continuationFunction, TaskScheduler scheduler) 1099return ContinueWith(continuationFunction, TaskScheduler.Current, default, continuationOptions); 1121/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 1151TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1157internal Task<TNewResult> ContinueWith<TNewResult>(Func<Task<TResult>, TNewResult> continuationFunction, TaskScheduler scheduler, 1212return ContinueWith(continuationFunction, state, TaskScheduler.Current, default, TaskContinuationOptions.None); 1243return ContinueWith(continuationFunction, state, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 1258/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 1273TaskScheduler scheduler) 1319return ContinueWith(continuationFunction, state, TaskScheduler.Current, default, continuationOptions); 1342/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 1372CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1379TaskScheduler scheduler, CancellationToken cancellationToken, TaskContinuationOptions continuationOptions)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (72)
127internal TaskScheduler? m_taskScheduler; // The task scheduler this task runs under. 651TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 684TaskCreationOptions creationOptions, InternalTaskOptions internalOptions, TaskScheduler? scheduler) 995internal void FireTaskScheduledIfNeeded(TaskScheduler ts) 1051/// cref="TaskScheduler">TaskScheduler</see>. 1064Start(TaskScheduler.Current); 1069/// cref="TaskScheduler">TaskScheduler</see>. 1076/// The <see cref="TaskScheduler">TaskScheduler</see> with which to associate 1087public void Start(TaskScheduler scheduler) 1125/// cref="TaskScheduler">TaskScheduler</see>. 1134/// cref="TaskScheduler">TaskScheduler</see>. 1149InternalRunSynchronously(TaskScheduler.Current, waitForCompletion: true); 1154/// cref="TaskScheduler">scheduler</see> provided. 1175public void RunSynchronously(TaskScheduler scheduler) 1188internal void InternalRunSynchronously(TaskScheduler scheduler, bool waitForCompletion) 1290Task? creatingTask, Delegate action, object? state, CancellationToken cancellationToken, TaskScheduler scheduler, 1601internal TaskScheduler? ExecutingTaskScheduler => m_taskScheduler; 2472log.TaskStarted(TaskScheduler.Current.Id, 0, this.Id); 2526log.TaskCompleted(TaskScheduler.Current.Id, 0, this.Id, IsFaulted); 2665if (TaskScheduler.InternalCurrent is TaskScheduler scheduler && scheduler != TaskScheduler.Default) 2736if (TaskScheduler.InternalCurrent is TaskScheduler scheduler && scheduler != TaskScheduler.Default) 3139currentTask != null ? currentTask.m_taskScheduler!.Id : TaskScheduler.Default.Id, currentTask != null ? currentTask.Id : 0, 3177log.TaskWaitEnd(TaskScheduler.Default.Id, 0, this.Id); 3336TaskScheduler? ts = m_taskScheduler; 3827return ContinueWith(continuationAction, TaskScheduler.Current, default, TaskContinuationOptions.None); 3849return ContinueWith(continuationAction, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 3860/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 3874public Task ContinueWith(Action<Task> continuationAction, TaskScheduler scheduler) 3909return ContinueWith(continuationAction, TaskScheduler.Current, default, continuationOptions); 3928/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 3948TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 3954private Task ContinueWith(Action<Task> continuationAction, TaskScheduler scheduler, 4005return ContinueWith(continuationAction, state, TaskScheduler.Current, default, TaskContinuationOptions.None); 4028return ContinueWith(continuationAction, state, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 4040/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 4054public Task ContinueWith(Action<Task, object?> continuationAction, object? state, TaskScheduler scheduler) 4090return ContinueWith(continuationAction, state, TaskScheduler.Current, default, continuationOptions); 4110/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 4130TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 4136private Task ContinueWith(Action<Task, object?> continuationAction, object? state, TaskScheduler scheduler, 4190return ContinueWith(continuationFunction, TaskScheduler.Current, default, 4219return ContinueWith(continuationFunction, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 4233/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 4247public Task<TResult> ContinueWith<TResult>(Func<Task, TResult> continuationFunction, TaskScheduler scheduler) 4285return ContinueWith(continuationFunction, TaskScheduler.Current, default, continuationOptions); 4307/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 4330TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 4336private Task<TResult> ContinueWith<TResult>(Func<Task, TResult> continuationFunction, TaskScheduler scheduler, 4390return ContinueWith(continuationFunction, state, TaskScheduler.Current, default, 4420return ContinueWith(continuationFunction, state, TaskScheduler.Current, cancellationToken, TaskContinuationOptions.None); 4435/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its execution. 4449public Task<TResult> ContinueWith<TResult>(Func<Task, object?, TResult> continuationFunction, object? state, TaskScheduler scheduler) 4488return ContinueWith(continuationFunction, state, TaskScheduler.Current, default, continuationOptions); 4511/// The <see cref="TaskScheduler"/> to associate with the continuation task and to use for its 4534TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 4540private Task<TResult> ContinueWith<TResult>(Func<Task, object?, TResult> continuationFunction, object? state, TaskScheduler scheduler, 4634TaskScheduler scheduler, 4696log.AwaitTaskContinuationScheduled(TaskScheduler.Current.Id, CurrentId ?? 0, continuationTask.Id); 5694return InternalStartNew(null, action, null, default, TaskScheduler.Default, 5712return InternalStartNew(null, action, null, cancellationToken, TaskScheduler.Default, 5727TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5745TaskCreationOptions.DenyChildAttach, InternalTaskOptions.None, TaskScheduler.Default); 5784Task<Task?> task1 = Task<Task?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 5828Task<Task<TResult>?> task1 = Task<Task<TResult>?>.Factory.StartNew(function, cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 7356/// A hint to a <see cref="TaskScheduler">TaskScheduler</see> to schedule a 7364/// <see cref="TaskScheduler">TaskScheduler</see> that oversubscription may be 7447/// A hint to a <see cref="TaskScheduler">TaskScheduler</see> to schedule a 7455/// a hint to the <see cref="TaskScheduler">TaskScheduler</see> that
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskContinuation.cs (15)
266private readonly TaskScheduler m_taskScheduler; 272internal ContinueWithTaskContinuation(Task task, TaskContinuationOptions options, TaskScheduler scheduler) 407log.AwaitTaskContinuationScheduled((task.ExecutingTaskScheduler ?? TaskScheduler.Default).Id, task.Id, m_continuationId); 456private readonly TaskScheduler m_scheduler; 463TaskScheduler scheduler, Action action, bool flowExecutionContext) : 476if (m_scheduler == TaskScheduler.Default) 491internal static void RunOrScheduleAction(Action action, TaskScheduler scheduler, ExecutionContext? capturedContext, bool allowInlining) 494Debug.Assert(scheduler != null && scheduler != TaskScheduler.Default); 503(TaskScheduler.InternalCurrent == scheduler || Thread.CurrentThread.IsThreadPoolThread); 561protected static Task CreateTask(Action<object?> action, object? state, TaskScheduler scheduler, ExecutionContext? capturedContext) 594log.AwaitTaskContinuationScheduled((task.ExecutingTaskScheduler ?? TaskScheduler.Default).Id, task.Id, m_continuationId); 629TaskScheduler? sched = TaskScheduler.InternalCurrent; 630return sched == null || sched == TaskScheduler.Default; 839log.AwaitTaskContinuationScheduled((task.ExecutingTaskScheduler ?? TaskScheduler.Default).Id, task.Id, atc.m_continuationId);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskExceptionHolder.cs (1)
68TaskScheduler.PublishUnobservedTaskException(m_task, ueea);
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory_T.cs (41)
35private readonly TaskScheduler? m_defaultScheduler; 39private TaskScheduler DefaultScheduler => m_defaultScheduler ?? TaskScheduler.Current; 42private TaskScheduler GetDefaultScheduler(Task? currTask) 49else return TaskScheduler.Default; 63/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 65/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 83/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 85/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 96/// The <see cref="TaskScheduler"> 106/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 109/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 111public TaskFactory(TaskScheduler? scheduler) // null means to use TaskScheduler.Current 138/// cref="TaskScheduler">TaskScheduler</see> property is initialized to the 140/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 166/// The default <see cref="TaskScheduler"> 181/// cref="TaskScheduler">TaskScheduler</see> property is initialized to 184/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 186public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 207/// Gets the <see cref="TaskScheduler">TaskScheduler</see> of this 213/// If null, <see cref="TaskScheduler.Current">TaskScheduler.Current</see> 216public TaskScheduler? Scheduler => m_defaultScheduler; 330/// cref="TaskScheduler">TaskScheduler</see> 353public Task<TResult> StartNew(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 457/// cref="TaskScheduler">TaskScheduler</see> 480public Task<TResult> StartNew(Func<object?, TResult> function, object? state, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 603/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 622TaskScheduler scheduler) 634TaskScheduler scheduler) 1432/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1458CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1568/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1594CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1606TaskContinuationOptions continuationOptions, CancellationToken cancellationToken, TaskScheduler scheduler) 1653TaskContinuationOptions continuationOptions, CancellationToken cancellationToken, TaskScheduler scheduler) 1802/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1828CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1938/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1964CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1975TaskContinuationOptions continuationOptions, CancellationToken cancellationToken, TaskScheduler scheduler) 2026TaskContinuationOptions continuationOptions, CancellationToken cancellationToken, TaskScheduler scheduler)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (50)
38private readonly TaskScheduler? m_defaultScheduler; 42private TaskScheduler DefaultScheduler => m_defaultScheduler ?? TaskScheduler.Current; 45private TaskScheduler GetDefaultScheduler(Task? currTask) 50TaskScheduler.Default); 68/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 70/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 88/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 90/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 101/// The <see cref="TaskScheduler"> 111/// and the <see cref="TaskScheduler">TaskScheduler</see> property is 114/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 116public TaskFactory(TaskScheduler? scheduler) // null means to use TaskScheduler.Current 143/// cref="TaskScheduler">TaskScheduler</see> property is initialized to the 145/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 171/// The default <see cref="TaskScheduler"> 186/// cref="TaskScheduler">TaskScheduler</see> property is initialized to 189/// cref="TaskScheduler.Current">TaskScheduler.Current</see>). 191public TaskFactory(CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskContinuationOptions continuationOptions, TaskScheduler? scheduler) 227/// Gets the <see cref="TaskScheduler">TaskScheduler</see> of this 233/// If null, <see cref="TaskScheduler.Current">TaskScheduler.Current</see> 236public TaskScheduler? Scheduler => m_defaultScheduler; 345/// cref="TaskScheduler">TaskScheduler</see> 368public Task StartNew(Action action, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 470/// cref="TaskScheduler">TaskScheduler</see> 494TaskCreationOptions creationOptions, TaskScheduler scheduler) 603/// cref="TaskScheduler">TaskScheduler</see> 626public Task<TResult> StartNew<TResult>(Func<TResult> function, CancellationToken cancellationToken, TaskCreationOptions creationOptions, TaskScheduler scheduler) 743/// cref="TaskScheduler">TaskScheduler</see> 767TaskCreationOptions creationOptions, TaskScheduler scheduler) 834/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 853TaskScheduler scheduler) 1198/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1214IAsyncResult asyncResult, Func<IAsyncResult, TResult> endMethod, TaskCreationOptions creationOptions, TaskScheduler scheduler) 1779/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1805TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 1916/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 1942CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2063/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2089TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2216/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2242CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2495/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2521TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2642/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2668TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2794/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2820CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler) 2931/// <param name="scheduler">The <see cref="TaskScheduler">TaskScheduler</see> 2957CancellationToken cancellationToken, TaskContinuationOptions continuationOptions, TaskScheduler scheduler)
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (35)
23/// <see cref="TaskScheduler">TaskScheduler</see> acts as the extension point for all 28/// All members of the abstract <see cref="TaskScheduler"/> type are thread-safe 46/// A class derived from <see cref="TaskScheduler">TaskScheduler</see> 67/// A class derived from <see cref="TaskScheduler">TaskScheduler</see> implements this function to 109/// A class derived from <see cref="TaskScheduler"/> implements this method in order to support 148/// <see cref="TaskScheduler"/> is able to support. 170TaskScheduler? ets = task.ExecutingTaskScheduler; 241private static ConditionalWeakTable<TaskScheduler, object?>? s_activeTaskSchedulers; 244private static readonly TaskScheduler s_defaultTaskScheduler = new ThreadPoolTaskScheduler(); 260/// Initializes the <see cref="TaskScheduler"/>. 279ConditionalWeakTable<TaskScheduler, object?>? activeTaskSchedulers = s_activeTaskSchedulers; 282Interlocked.CompareExchange(ref s_activeTaskSchedulers, new ConditionalWeakTable<TaskScheduler, object?>(), null); 289/// Gets the default <see cref="TaskScheduler">TaskScheduler</see> instance. 291public static TaskScheduler Default => s_defaultTaskScheduler; 294/// Gets the <see cref="TaskScheduler">TaskScheduler</see> 300public static TaskScheduler Current => InternalCurrent ?? Default; 303/// Gets the <see cref="TaskScheduler">TaskScheduler</see> 309internal static TaskScheduler? InternalCurrent 321/// Creates a <see cref="TaskScheduler"/> 331/// A <see cref="TaskScheduler"/> associated with 338public static TaskScheduler FromCurrentSynchronizationContext() 344/// Gets the unique ID for this <see cref="TaskScheduler"/>. 474/// Provides an array of all active <see cref="TaskScheduler">TaskScheduler</see> 481/// <returns>An array of <see cref="TaskScheduler">TaskScheduler</see> instances.</returns> 482internal static TaskScheduler[] GetTaskSchedulersForDebugger() 490List<TaskScheduler> schedulers = new List<TaskScheduler>(); 491foreach (KeyValuePair<TaskScheduler, object?> item in s_activeTaskSchedulers) 503TaskScheduler[] arr = schedulers.ToArray(); 504foreach (TaskScheduler scheduler in arr) 517private readonly TaskScheduler m_taskScheduler; 518public SystemThreadingTasks_TaskSchedulerDebugView(TaskScheduler scheduler) 552/// Implementation of <see cref="TaskScheduler.QueueTask"/> for this scheduler class. 563/// Implementation of <see cref="TaskScheduler.TryExecuteTaskInline"/> for this scheduler class. 588/// Implements the <see cref="TaskScheduler.MaximumConcurrencyLevel"/> property for
src\runtime\src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskSchedulerException.cs (1)
20/// <see cref="TaskScheduler"/>.
System.Runtime (1)
src\runtime\artifacts\obj\System.Runtime\Release\net11.0\System.Runtime.Forwards.cs (1)
852[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]
System.Runtime.InteropServices.JavaScript (4)
System\Runtime\InteropServices\JavaScript\JSHostImplementation.cs (1)
254}, TaskScheduler.Default);
System\Runtime\InteropServices\JavaScript\Marshaling\JSMarshalerArgument.Task.cs (3)
221task.ContinueWith(Complete, taskHolder, TaskScheduler.Current); 307task.ContinueWith(Complete, taskHolder, TaskScheduler.Current); 386task.ContinueWith(Complete, new HolderAndMarshaler<T>(taskHolder, marshaler), TaskScheduler.Current);
System.ServiceModel.Federation (5)
System\Runtime\OperationWithTimeoutAsyncResult.cs (1)
25_ = Task.Factory.StartNew(s_scheduledCallback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\Runtime\TaskHelpers.cs (4)
33}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 63}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 87}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 119}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default);
System.ServiceModel.Http (1)
System\ServiceModel\Channels\MessageContent.cs (1)
198}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.ServiceModel.Primitives (11)
Internals\System\Runtime\IOThreadScheduler.cs (4)
58private static TaskScheduler s_IOTaskScheduler; 88public static TaskScheduler IOTaskScheduler 96s_IOTaskScheduler = TaskScheduler.FromCurrentSynchronizationContext(); 131Task.Factory.StartNew(callback, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Internals\System\Runtime\TaskHelpers.cs (6)
48}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 78}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 102}, callback, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 134}, continuationState, CancellationToken.None, TaskContinuationOptions.HideScheduler, TaskScheduler.Default); 442return (TaskScheduler.Current == TaskScheduler.Default) &&
System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1202Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System.ServiceModel.Primitives.Tests (1)
ServiceModel\ThrowingOnCloseBindingElement.cs (1)
175}, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);
System.Text.RegularExpressions (11)
System\Threading\StackHelper.cs (11)
40.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 51.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 64.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 79.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 96.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 115.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 123.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 133.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 145.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 159.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 175.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default)
System.Text.RegularExpressions.Generator (11)
src\runtime\src\libraries\System.Text.RegularExpressions\src\System\Threading\StackHelper.cs (11)
40.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 51.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 64.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 79.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 96.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 115.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 123.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 133.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 145.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 159.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default) 175.ContinueWith(t => t.GetAwaiter().GetResult(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default)
System.Threading.Channels (8)
System\Threading\Channels\AsyncOperation.cs (8)
248TaskScheduler? ts = 249ctx as TaskScheduler ?? 250(ctx as CapturedSchedulerAndExecutionContext)?._scheduler as TaskScheduler; 252if (RunContinuationsAsynchronously || ts != TaskScheduler.Current) 331TaskScheduler? ts = null; 344ts = TaskScheduler.Current; 345if (ts != TaskScheduler.Default) 421Debug.Assert(scheduler is SynchronizationContext or TaskScheduler, $"{nameof(scheduler)} is {scheduler}");
System.Threading.Tasks (1)
System.Threading.Tasks.cs (1)
34[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]
System.Threading.Tasks.Dataflow (58)
Base\DataflowBlock.cs (13)
513CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 527CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 1296}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1307}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1328}, this, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Default); 1839TaskScheduler scheduler = dataflowBlockOptions.TaskScheduler; 1868ISourceBlock<T> source, Action<T> action, int branchId, TaskScheduler scheduler, 1926TaskScheduler scheduler = dataflowBlockOptions.TaskScheduler; 1988}, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 2003TaskScheduler scheduler, 2388TaskScheduler.Default); 2401TaskScheduler.Default); 2402}, this, Canceler.Token, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default);
Base\DataflowBlockOptions.cs (7)
32/// <description><see cref="System.Threading.Tasks.TaskScheduler.Default"/></description> 69private TaskScheduler _taskScheduler = TaskScheduler.Default; 107/// <summary>Gets or sets the <see cref="System.Threading.Tasks.TaskScheduler"/> to use for scheduling tasks.</summary> 108public TaskScheduler TaskScheduler 214/// <description><see cref="System.Threading.Tasks.TaskScheduler.Default"/></description> 346/// <description><see cref="System.Threading.Tasks.TaskScheduler.Default"/></description>
Blocks\ActionBlock.cs (1)
190}, this, CancellationToken.None, Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default);
Blocks\BatchBlock.cs (4)
75CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 86}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 547}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 655exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Blocks\BatchedJoinBlock.cs (2)
104}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 353}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
Blocks\BroadcastBlock.cs (6)
93}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 271exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 404}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 650}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 864}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 947this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Blocks\BufferBlock.cs (3)
75}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 272exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 407}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Blocks\JoinBlock.cs (5)
86CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 97}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 305CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 316}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 1335}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Blocks\TransformBlock.cs (3)
145}, _source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 156}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default); 262Common.GetContinuationOptions(TaskContinuationOptions.ExecuteSynchronously), TaskScheduler.Default);
Blocks\TransformManyBlock.cs (2)
144}, source, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default); 155}, this, CancellationToken.None, Common.GetContinuationOptions() | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);
Blocks\TransformManyBlock.netstandard21.cs (1)
40t.ContinueWith(static t => Debug.Assert(t.IsCompletedSuccessfully), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);
Blocks\WriteOnceBlock.cs (1)
142Tuple.Create(this, exceptions), CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Internal\Common.cs (5)
205reg, cancellationToken, Common.GetContinuationOptions(), TaskScheduler.Default); 452internal static Exception? StartTaskSafe(Task task, TaskScheduler scheduler) 457if (scheduler == TaskScheduler.Default) 470private static Exception? StartTaskSafeCore(Task task, TaskScheduler scheduler) 574target, CancellationToken.None, Common.GetContinuationOptions(), TaskScheduler.Default);
Internal\SourceCore.cs (3)
523}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 786}, this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 920this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
Internal\TargetCore.cs (2)
390exception, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default); 746this, CancellationToken.None, Common.GetCreationOptionsForTask(), TaskScheduler.Default);
System.Threading.Tasks.Parallel (36)
System\Threading\Tasks\Parallel.cs (16)
33private TaskScheduler? _scheduler; 49_scheduler = TaskScheduler.Default; 55/// Gets or sets the <see cref="System.Threading.Tasks.TaskScheduler">TaskScheduler</see> 59public TaskScheduler? TaskScheduler 66internal TaskScheduler EffectiveTaskScheduler => _scheduler ?? TaskScheduler.Current; 223ParallelEtwProvider.Log.ParallelInvokeBegin(TaskScheduler.Current.Id, Task.CurrentId ?? 0, 362ParallelEtwProvider.Log.ParallelInvokeEnd(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID); 968ParallelEtwProvider.Log.ParallelLoopBegin(TaskScheduler.Current.Id, Task.CurrentId ?? 0, 1005ParallelEtwProvider.Log.ParallelFork(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID); 1105ParallelEtwProvider.Log.ParallelJoin(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID); 1150ParallelEtwProvider.Log.ParallelLoopEnd(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID, long.CreateTruncating(nTotalIterations)); 2535ParallelEtwProvider.Log.ParallelLoopBegin(TaskScheduler.Current.Id, Task.CurrentId ?? 0, 2596ParallelEtwProvider.Log.ParallelFork(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID); 2741ParallelEtwProvider.Log.ParallelJoin(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID); 2789ParallelEtwProvider.Log.ParallelLoopEnd(TaskScheduler.Current.Id, Task.CurrentId ?? 0, forkJoinContextID, 0);
System\Threading\Tasks\Parallel.ForEachAsync.cs (18)
27return ForAsync(fromInclusive, toExclusive, DefaultDegreeOfParallelism, TaskScheduler.Default, default, body); 45return ForAsync(fromInclusive, toExclusive, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 77private static Task ForAsync<T>(T fromInclusive, T toExclusive, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<T, CancellationToken, ValueTask> body) 203return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 219return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 247private static Task ForEachAsync<TSource>(IEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 358return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, default(CancellationToken), body); 374return ForEachAsync(source, DefaultDegreeOfParallelism, TaskScheduler.Default, cancellationToken, body); 402private static Task ForEachAsync<TSource>(IAsyncEnumerable<TSource> source, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 520/// <summary>The <see cref="TaskScheduler"/> on which all work should be performed.</summary> 521private readonly TaskScheduler _scheduler; 540protected ForEachAsyncState(Func<object, Task> taskBody, bool needsLock, int dop, TaskScheduler scheduler, CancellationToken cancellationToken, Func<TSource, CancellationToken, ValueTask> body) 547if (scheduler == TaskScheduler.Default) 572if (_scheduler == TaskScheduler.Default) 671Debug.Assert(_scheduler == TaskScheduler.Default, $"Expected {nameof(_scheduler)} == TaskScheduler.Default, got {_scheduler}"); 692int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 714int dop, TaskScheduler scheduler, CancellationToken cancellationToken, 737int dop, TaskScheduler scheduler, CancellationToken cancellationToken,
System\Threading\Tasks\TaskReplicator.cs (2)
19private readonly TaskScheduler _scheduler; 127_scheduler = options.TaskScheduler ?? TaskScheduler.Current;
System.Windows.Forms.Primitives (1)
System\Windows\Forms\Animation\HighPrecisionTimer.cs (1)
724TaskScheduler.Default);
UnitTests.Common (1)
TestTypes.cs (1)
346t.ContinueWith(delegate { syncCtx.Complete(); }, TaskScheduler.Default);
VBCSCompiler (1)
src\roslyn\src\Compilers\Server\VBCSCompiler\ServerDispatcher.cs (1)
111_listenTask.ContinueWith(_ => { }, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default)