TaskScheduler

Shared\Utilities\ThreadingContextTaskSchedulerProvider.cs (1)

24private sealed class JoinableTaskFactoryTaskScheduler(JoinableTaskFactory joinableTaskFactory) : TaskScheduler

Threading\SynchronizationContextTaskScheduler.cs (1)

15internal sealed class SynchronizationContextTaskScheduler : TaskScheduler

TestExportJoinableTaskContext.cs (1)

132private sealed class JoinableTaskFactoryTaskScheduler : TaskScheduler

src\VisualStudio\IntegrationTest\Harness\XUnitShared\Threading\SynchronizationContextTaskScheduler.cs (1)

13public class SynchronizationContextTaskScheduler : TaskScheduler

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ConcurrentExclusiveSchedulerPair.cs (1)

507private sealed class ConcurrentExclusiveTaskScheduler : TaskScheduler

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (1)

536internal sealed class SynchronizationContextTaskScheduler : TaskScheduler

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\ThreadPoolTaskScheduler.cs (1)

22internal sealed class ThreadPoolTaskScheduler : TaskScheduler

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);

src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)

122}, TaskScheduler.Default);

src\Shared\CoalescingAsyncOperation.cs (1)

51}, this, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

src\Aspire.Hosting\Dcp\Process\ProcessUtil.cs (1)

122}, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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();

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();

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

ConsumerWorker.cs (1)

39}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);

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();

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);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

Startup.cs (1)

69TaskScheduler.UnobservedTaskException += (sender, e) =>

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

Rendering\WebAssemblyDispatcher.cs (2)

112}, TaskScheduler.FromCurrentSynchronizationContext()); 156}, TaskScheduler.FromCurrentSynchronizationContext());

PhotinoSynchronizationContext.cs (1)

240}, CancellationToken.None, flags, TaskScheduler.Current);

PhotinoWebViewManager.cs (1)

43}, message, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

KeyManagement\KeyRingProvider.cs (2)

371TaskScheduler.Default); 413TaskScheduler.Default)

RedisOutputCacheStore.cs (1)

88_ = Task.Factory.StartNew(RunGarbageCollectionLoopAsync, default, TaskCreationOptions.LongRunning, TaskScheduler.Current);

WebSockets\OwinWebSocketAcceptAdapter.cs (1)

129adapter.UpstreamTask.ContinueWith(adapter.EnsureCompleted, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

HubConnection.cs (1)

617TaskScheduler.Default);

Util\EventedStreamReader.cs (1)

30Task.Factory.StartNew(Run, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

HttpContextBuilder.cs (1)

157_ = Task.Factory.StartNew(RunRequestAsync, default, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

DiagnosticAnalyzer\AnalyzerDriver.cs (1)

688.ContinueWith(c => DiagnosticQueue.TryComplete(), cancellationToken, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

DiagnosticAnalyzer\AsyncQueue.cs (1)

326TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

EventHookup\EventHookupSessionManager_EventHookupSession.cs (1)

128await TaskScheduler.Default;

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

AddImports\AbstractAddImportsPasteCommandHandler.cs (1)

147await TaskScheduler.Default;

DocumentationComments\CopilotGenerateDocumentationCommentProvider.cs (1)

77await TaskScheduler.Default;

GoOrFind\AbstractGoOrFindNavigationService.cs (3)

150await TaskScheduler.Default; 229await TaskScheduler.Default; 262await TaskScheduler.Default.SwitchTo(alwaysYield: true);

GoToDefinition\GoToDefinitionCommandHandler.cs (1)

121await TaskScheduler.Default;

InlineHints\InlineHintsTag.cs (1)

262await TaskScheduler.Default;

InlineRename\InlineRenameSession.cs (4)

309await TaskScheduler.Default; 539await TaskScheduler.Default; 568await TaskScheduler.Default; 831await TaskScheduler.Default;

IntelliSense\AsyncCompletion\CommitManager.cs (1)

334await TaskScheduler.Default;

IntelliSense\AsyncCompletion\ItemManager.CompletionListUpdater.cs (1)

256await TaskScheduler.Default;

IntelliSense\ModelComputation.cs (2)

141_stopCancellationToken, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default).Unwrap(); 150await TaskScheduler.Default;

LanguageServer\AlwaysActiveLanguageClientEventListener.cs (1)

79await TaskScheduler.Default.SwitchTo(alwaysYield: true);

NavigationBar\NavigationBarController_ModelComputation.cs (1)

91await TaskScheduler.Default;

Organizing\OrganizeDocumentCommandHandler.cs (1)

139await TaskScheduler.Default;

RenameTracking\RenameTrackingTaggerProvider.TrackingSession.cs (2)

140await TaskScheduler.Default; 164await TaskScheduler.Default;

Shared\Utilities\ThreadingContextTaskSchedulerProvider.cs (2)

20public TaskScheduler CurrentContextScheduler { get; } = threadingContext.HasMainThread 22: TaskScheduler.Default;

Suggestions\SuggestedActions\EditorSuggestedAction.cs (3)

66await TaskScheduler.Default; 74await TaskScheduler.Default; 81await TaskScheduler.Default;

Suggestions\SuggestedActionsSource.cs (4)

135await TaskScheduler.Default; 171await TaskScheduler.Default; 194await TaskScheduler.Default.SwitchTo(alwaysYield: true); 245await TaskScheduler.Default.SwitchTo(alwaysYield: true);

Tagging\AbstractAsynchronousTaggerProvider.TagSource_ProduceTags.cs (1)

337await TaskScheduler.Default;

Workspaces\ITextBufferVisibilityTracker.cs (1)

72CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

Threading\TaskJoinExtensions.cs (1)

47TaskScheduler.Default);

Utilities\AsynchronousOperationListenerTests.cs (15)

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

Cohost\RazorStartupServiceFactory.cs (1)

85await TaskScheduler.Default.SwitchTo(alwaysYield: true);

ExternalAccess\UnitTesting\SolutionCrawler\UnitTestingWorkCoordinator.UnitTestingSemanticChangeProcessor.cs (2)

64TaskScheduler.Default); 354TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

HostWorkspace\FileWatching\LspFileChangeWatcher.cs (1)

267}, CancellationToken.None, TaskContinuationOptions.OnlyOnRanToCompletion, TaskScheduler.Default).Unwrap().ReportNonFatalErrorAsync().CompletesAsyncOperation(asyncToken);

Features\Suggestions\UnifiedSuggestedActionsSource.cs (2)

46await TaskScheduler.Default; 430await TaskScheduler.Default;

src\LanguageServer\Microsoft.CommonLanguageServerProtocol.Framework\RequestExecutionQueue.cs (2)

178_ = resultTask.ContinueWith(_ => combinedTokenSource.Dispose(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 403}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

Utilities\BrokeredServiceProxy.cs (2)

35await TaskScheduler.Default.SwitchTo(alwaysYield: true); 50await TaskScheduler.Default.SwitchTo(alwaysYield: true);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

Host\SolutionAssetSource.cs (1)

28await TaskScheduler.Default;

BrokeredServiceConnection.cs (1)

83await TaskScheduler.Default;

CancellationTokenSourceExtensions.cs (1)

39TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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; 42private readonly TaskScheduler _scheduler; 54_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\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

Storage\SQLite\v2\SQLitePersistentStorage.Accessor.cs (3)

166Contract.ThrowIfFalse(TaskScheduler.Current == this.Storage.Scheduler.ConcurrentScheduler); 225Contract.ThrowIfFalse(TaskScheduler.Current == this.Storage.Scheduler.ExclusiveScheduler); 364Contract.ThrowIfFalse(TaskScheduler.Current == this.Storage.Scheduler.ExclusiveScheduler);

Storage\SQLite\v2\SQLitePersistentStorage_FlushWrites.cs (1)

35Contract.ThrowIfFalse(TaskScheduler.Current == this.Scheduler.ExclusiveScheduler);

Storage\SQLite\v2\SQLitePersistentStorage_StringIds.cs (3)

49TaskScheduler.Current == this.Scheduler.ExclusiveScheduler || 50TaskScheduler.Current == this.Scheduler.ConcurrentScheduler); 67Contract.ThrowIfFalse(TaskScheduler.Current == this.Scheduler.ExclusiveScheduler);

Storage\SQLite\v2\SQLitePersistentStorage_Threading.cs (1)

17TaskScheduler scheduler, CancellationToken cancellationToken) where TArg : struct

Storage\SQLite\v2\SQLitePersistentStorage+PooledConnection.cs (2)

42var scheduler = TaskScheduler.Current;

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;

Rpc\RpcServer.cs (1)

86TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

RpcTests.cs (1)

49ServerCompletion = Server.RunAsync().ContinueWith(_ => _serverStream.Dispose(), TaskScheduler.Default);

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

86TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

VisualStudioMSBuildWorkspaceTests.cs (1)

985await Task.Delay(delay).ContinueWith(t => file.Close(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

UtilityTest\AsyncLazyTests.cs (2)

78}, CancellationToken.None, TaskCreationOptions.None, TaskScheduler.Current); 98TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

RequestExecutionQueue.cs (2)

178_ = resultTask.ContinueWith(_ => combinedTokenSource.Dispose(), CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 403}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

CacheEntry.CacheEntryTokens.cs (1)

110CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

CacheEntry.cs (1)

288}, obj, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

MemoryCache.cs (1)

398CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

ServiceLookup\StackGuard.cs (1)

68Task<R> task = Task.Factory.StartNew((Func<object?, R>)action, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

PhysicalFilesWatcher.cs (1)

457TaskScheduler.Default);

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);

Internals\AsyncValue.cs (2)

48 TaskScheduler scheduler = TaskScheduler.FromCurrentSynchronizationContext();

src\Graphics\src\Graphics\Platforms\Windows\AsyncPump.cs (2)

44 { syncCtx.Complete(); }, TaskScheduler.Default); 75 { syncCtx.Complete(); }, TaskScheduler.Default);

AsyncTaskExtensions.cs (1)

34 TaskScheduler = TaskScheduler.Default,

Utilities\ResourceManagerUtils.cs (1)

163var timeoutTask = Task.Delay(timeout).ContinueWith(task => default(Exception), TaskScheduler.Default);

Microsoft\VisualBasic\ApplicationServices\SingleInstanceTests.cs (4)

119}, cancellationToken: default, creationOptions: default, scheduler: TaskScheduler.Default)).ToArray(); 157var tasks = Enumerable.Range(0, n).Select(i => Task.Factory.StartNew(() => { Assert.True(SendSecondInstanceArgs(pipeName, SendTimeout, sentArgs[i])); }, cancellationToken: default, creationOptions: default, scheduler: TaskScheduler.Default)).ToArray(); 214var task = Task.Factory.StartNew(() => SendSecondInstanceArgs(pipeName, timeout: 300, []), cancellationToken: TestContext.Current.CancellationToken, creationOptions: default, scheduler: TaskScheduler.Default); 229var task = Task.Factory.StartNew(() => SendSecondInstanceArgs(pipeName, SendTimeout, ["1", "ABC"]), cancellationToken: TestContext.Current.CancellationToken, creationOptions: default, scheduler: TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\VisualStudio\IntegrationTest\Harness\XUnitShared\Threading\SemaphoreExtensions.cs (1)

38TaskScheduler.Default);

CodeCleanup\AbstractCodeCleanUpFixer.cs (2)

90await TaskScheduler.Default; 115await TaskScheduler.Default;

DocumentOutline\DocumentOutlineViewModel.cs (2)

265await TaskScheduler.Default; 288await TaskScheduler.Default;

EditorConfigSettings\SettingsEditorPane.SearchTask.cs (1)

43await TaskScheduler.Default;

LanguageService\AbstractPackage`2.cs (1)

60await TaskScheduler.Default;

LanguageService\PackageLoadTasks.cs (1)

64await TaskScheduler.Default;

Library\ObjectBrowser\AbstractObjectBrowserLibraryManager.cs (1)

523await TaskScheduler.Default;

NavigateTo\RoslynSearchItemsSource.cs (1)

69await TaskScheduler.Default.SwitchTo(alwaysYield: true);

Packaging\PackageInstallerServiceFactory.cs (4)

221await TaskScheduler.Default; 315await TaskScheduler.Default; 387await TaskScheduler.Default; 500await TaskScheduler.Default;

ProjectSystem\FileChangeTracker.cs (1)

138s_lastBackgroundTask = s_lastBackgroundTask.ContinueWith(_ => _fileChangeCookie.GetValueAsync(CancellationToken.None), CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default).Unwrap();

ProjectSystem\FileChangeWatcherProvider.cs (1)

39TaskScheduler.Default)

ProjectSystem\Logging\RoslynWorkspaceStructureLogger.cs (1)

89await TaskScheduler.Default;

Remote\VisualStudioWorkspaceServiceHubConnector.cs (1)

65TaskScheduler.Default);

Snippets\AbstractSnippetInfoService.cs (1)

123await TaskScheduler.Default;

SymbolSearch\VisualStudioSymbolSearchService.cs (1)

80await TaskScheduler.Default;

SemanticSearch\SemanticSearchPresenterController.cs (1)

36await TaskScheduler.Default;

SemanticSearch\SemanticSearchToolWindowController.cs (1)

49await TaskScheduler.Default;

SemanticSearch\SemanticSearchToolWindowImpl.cs (2)

201await TaskScheduler.Default; 429await TaskScheduler.Default;

CodeModel\ProjectCodeModelFactory.cs (1)

72await TaskScheduler.Default;

ProjectSystem\CPS\CPSProjectFactory.cs (1)

125await TaskScheduler.Default;

SolutionExplorer\SourceGeneratedFileItems\SourceGeneratedFileItemSource.cs (1)

233}, cancellationToken, TaskContinuationOptions.OnlyOnRanToCompletion, TaskScheduler.Default).Unwrap().CompletesAsyncOperation(asyncToken);

src\libraries\shims\mscorlib\ref\mscorlib.cs (1)

1168[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]

netstandard.cs (1)

2127[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]

OrderProcessingWorker.cs (1)

43}, stoppingToken, TaskCreationOptions.LongRunning, TaskScheduler.Current);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

OptionPages\ForceLowMemoryMode.cs (1)

80return Task.Factory.StartNew(() => this.PopulateAndMonitorWorkerAsync(size), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default).Unwrap();

ScenarioTestTypes.cs (1)

278t.ContinueWith(delegate { syncCtx.Complete(); }, TaskScheduler.Default);

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();

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

System\ComponentModel\BackgroundWorker.cs (1)

133TaskScheduler.Default

Common\System\Data\ProviderBase\DbConnectionFactory.cs (2)

89}, cancellationTokenSource.Token, TaskContinuationOptions.LongRunning, TaskScheduler.Default)!; 125}, TaskScheduler.Default);

System\IO\Pipes\NamedPipeClientStream.cs (1)

202}, (this, timeout, cancellationToken, startTime), cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

System\IO\Ports\SerialStream.Unix.cs (1)

686TaskScheduler.Default);

System\Linq\Expressions\StackGuard.cs (1)

68Task<R> task = Task.Factory.StartNew(action!, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

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\MessageProcessingHandler.cs (1)

103}, tcs, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)

1002CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.Http3.cs (2)

877}, altSvcBlocklistTimerCt, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 886}, altSvcBlocklistTimerCt, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

System\Net\Http\SocketsHttpHandler\Http3Connection.cs (2)

174}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 497}, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Current);

System\Net\Http\SocketsHttpHandler\HttpConnectionBase.cs (1)

208CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously | TaskContinuationOptions.OnlyOnFaulted, TaskScheduler.Default);

src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)

358TaskScheduler.Default);

System\Net\Dns.cs (3)

143}, hostNameOrAddress, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 919}, key, cancellationToken, TaskContinuationOptions.DenyChildAttach, TaskScheduler.Default); 933}, key, CancellationToken.None, TaskContinuationOptions.OnlyOnCanceled | TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

System\Net\NetworkInformation\UnixIPGlobalProperties.cs (1)

57CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

System\Net\NetworkInformation\Ping.cs (1)

530}, AsyncOperationManager.CreateOperation(userToken), CancellationToken.None, TaskContinuationOptions.DenyChildAttach, TaskScheduler.Default);

System\Net\Quic\Internal\ResettableValueTaskSource.cs (1)

328}, handle, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default);

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\ManagedWebSocket.cs (1)

1883TaskScheduler.Default);

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\libraries\System.Private.CoreLib\src\System\IO\Stream.cs (3)

194cancellationToken, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default); 569}, readWriteTask, default, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default); 581readWriteTask.m_taskScheduler = TaskScheduler.Default;

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\libraries\System.Private.CoreLib\src\System\IO\TextWriter.cs (11)

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\TaskAwaiter.cs (2)

235currentTaskAtBegin != null ? currentTaskAtBegin.m_taskScheduler!.Id : TaskScheduler.Default.Id, 262currentTaskAtEnd != null ? currentTaskAtEnd.m_taskScheduler!.Id : TaskScheduler.Default.Id,

src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (7)

95TaskScheduler scheduler = TaskScheduler.Current; 96if (scheduler == TaskScheduler.Default) 136TaskScheduler scheduler = TaskScheduler.Current; 137if (scheduler == TaskScheduler.Default) 157TplEventSource.Log.AwaitTaskContinuationScheduled(TaskScheduler.Current.Id, (currentTask != null) ? currentTask.Id : 0, continuationId);

src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)

347}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

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\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\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (10)

144TaskScheduler ts = TaskScheduler.Current; 145if (ts != TaskScheduler.Default) 246Debug.Assert(context is TaskScheduler or SynchronizationContext, $"context is {context}"); 261Debug.Assert(scheduler is SynchronizationContext or TaskScheduler, $"{nameof(scheduler)} is {scheduler}"); 282context is SynchronizationContext or TaskScheduler or CapturedSchedulerAndExecutionContext, 291case TaskScheduler ts: 303Debug.Assert(cc._scheduler is TaskScheduler, $"{nameof(cc._scheduler)} is {cc._scheduler}"); 304ScheduleTaskScheduler((TaskScheduler)cc._scheduler, continuation, state); 312static void ScheduleTaskScheduler(TaskScheduler scheduler, Action<object?> continuation, object? state) =>

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (72)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task_T.cs (36)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskContinuation.cs (13)

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) 489(TaskScheduler.InternalCurrent == m_scheduler || Thread.CurrentThread.IsThreadPoolThread); 547protected Task CreateTask(Action<object?> action, object? state, TaskScheduler scheduler) 580log.AwaitTaskContinuationScheduled((task.ExecutingTaskScheduler ?? TaskScheduler.Default).Id, task.Id, m_continuationId); 615TaskScheduler? sched = TaskScheduler.InternalCurrent; 616return sched == null || sched == TaskScheduler.Default; 818log.AwaitTaskContinuationScheduled((task.ExecutingTaskScheduler ?? TaskScheduler.Default).Id, task.Id, atc.m_continuationId);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskExceptionHolder.cs (1)

68TaskScheduler.PublishUnobservedTaskException(m_task, ueea);

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (50)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory_T.cs (41)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskScheduler.cs (35)

src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskSchedulerException.cs (1)

20/// <see cref="TaskScheduler"/>.

src\System\Runtime\CompilerServices\AsyncHelpers.CoreCLR.cs (9)

647TaskScheduler? sched = TaskScheduler.InternalCurrent; 648if (sched == null || sched == TaskScheduler.Default) 689Debug.Assert(continuationContext is TaskScheduler { }); 690TaskScheduler sched = (TaskScheduler)continuationContext; 885TaskScheduler? sched = TaskScheduler.InternalCurrent; 886if (sched != null && sched != TaskScheduler.Default)

artifacts\obj\System.Runtime\Debug\net11.0\System.Runtime.Forwards.cs (1)

839[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]

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\Channels\MessageContent.cs (1)

198}, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);

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);

ServiceModel\ThrowingOnCloseBindingElement.cs (1)

175}, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

System\Threading\StackHelper.cs (11)

src\libraries\System.Text.RegularExpressions\src\System\Threading\StackHelper.cs (11)

System\Threading\Channels\AsyncOperation.cs (8)

243TaskScheduler? ts = 244ctx as TaskScheduler ?? 245(ctx as CapturedSchedulerAndExecutionContext)?._scheduler as TaskScheduler; 247if (RunContinuationsAsynchronously || ts != TaskScheduler.Current) 323TaskScheduler? ts = null; 336ts = TaskScheduler.Current; 337if (ts != TaskScheduler.Default) 404Debug.Assert(scheduler is SynchronizationContext or TaskScheduler, $"{nameof(scheduler)} is {scheduler}");

System.Threading.Tasks.cs (1)

34[assembly: System.Runtime.CompilerServices.TypeForwardedTo(typeof(System.Threading.Tasks.TaskScheduler))]

Base\DataflowBlock.cs (13)

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.cs (16)

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;

Startup.cs (1)

41TaskScheduler.UnobservedTaskException += (sender, e) =>

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

src\Dependencies\Contracts\ErrorReporting\FatalError.cs (2)

234TaskScheduler.Default); 244TaskScheduler.Default);

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\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\AsyncLazy`1.cs (1)

435TaskScheduler.Default);

src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\IAsyncEnumerableExtensions.cs (1)

82channel, CancellationToken.None, TaskContinuationOptions.None, TaskScheduler.Default);

TestTypes.cs (1)

346t.ContinueWith(delegate { syncCtx.Complete(); }, TaskScheduler.Default);

src\Compilers\Server\VBCSCompiler\ServerDispatcher.cs (1)

111_listenTask.ContinueWith(_ => { }, CancellationToken.None, TaskContinuationOptions.ExecuteSynchronously, TaskScheduler.Default)