165 references to Factory
BasicWebSite (1)
Controllers\AsyncActionsController.cs (1)
202Task.Factory.StartNew(() =>
Client.ChannelLayer.IntegrationTests (18)
DuplexChannelShapeTests.4.0.0.cs (6)
93Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 97Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 108Task.Factory.FromAsync((asyncCallback, o) => channel.BeginSend(requestMessage, asyncCallback, o), 111replyMessage = Task.Factory.FromAsync(channel.BeginReceive, channel.EndReceive, TaskCreationOptions.None).GetAwaiter().GetResult(); 125Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 126Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
DuplexChannelWithSynchronizationContext.cs (2)
152Task.Factory.StartNew(() => SingleThreadedSyncContext_CallbackUsingDefaultSyncCtx_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 217Task.Factory.StartNew(() => SingleThreadedSyncContext_SyncCallNotBlocked_Helper(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
RequestReplyChannelShapeTests.4.0.0.cs (10)
143Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 147Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 157replyMessage = Task.Factory.FromAsync((asyncCallback, o) => channel.BeginRequest(requestMessage, asyncCallback, o), 171Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 172Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 199Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 203Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, TaskCreationOptions.None).GetAwaiter().GetResult(); 213replyMessage = Task.Factory.FromAsync((asyncCallback, o) => channel.BeginRequest(requestMessage, asyncCallback, o), 228Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult(); 229Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None).GetAwaiter().GetResult();
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();
Consumer (1)
ConsumerWorker.cs (1)
13return Task.Factory.StartNew(async () =>
Contract.Service.IntegrationTests (13)
ServiceContractTests.4.0.0.cs (8)
307Task t = Task.Factory.FromAsync(factory.BeginOpen, factory.EndOpen, TaskCreationOptions.None); 336Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 361Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginOpen, proxyAsCommunicationObject.EndOpen, TaskCreationOptions.None); 389Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Open_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 416Task t = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None); 440Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_ChannelFactory(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 465Task t = Task.Factory.FromAsync(proxyAsCommunicationObject.BeginClose, proxyAsCommunicationObject.EndClose, TaskCreationOptions.None); 490Task.Factory.StartNew(() => ServiceContractTests.BasicHttp_Async_Close_Proxy(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait();
ServiceContractTests.4.1.0.cs (5)
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(); 879Task factoryTask = Task.Factory.FromAsync(factory.BeginClose, factory.EndClose, TaskCreationOptions.None);
dotnet-svcutil-lib (6)
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\System\ServiceModel\Description\MetadataExchangeClient.cs (3)
291return Task.Factory.FromAsync<MetadataRetriever, MetadataSet>(this.BeginGetMetadata, this.EndGetMetadata, retriever, /* state */ null); 301return Task.Factory.FromAsync<MetadataRetriever, MetadataSet>(this.BeginGetMetadata, this.EndGetMetadata, new MetadataReferenceRetriever(address, this), /* state */ null); 316return Task.Factory.FromAsync<MetadataRetriever, MetadataSet>(this.BeginGetMetadata, this.EndGetMetadata, new MetadataReferenceRetriever(address, via, this), /* state */ null);
FrameworkFork\System.ServiceModel\System\ServiceModel\Dispatcher\DuplexChannelBinder.cs (1)
1183Task.Factory.StartNew(s_receiveThreadSchedulerCallback, result, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.AspNetCore.Components.WebView.Photino (1)
PhotinoWebViewManager.cs (1)
35Task.Factory.StartNew(message =>
Microsoft.AspNetCore.Components.WebView.WindowsForms (3)
WindowsFormsDispatcher.cs (3)
52 await Task.Factory.FromAsync(asyncResult, _dispatchThreadControl.EndInvoke); 96 await Task.WhenAll(tcs.Task, Task.Factory.FromAsync(asyncResult, _dispatchThreadControl.EndInvoke)); 164 await Task.WhenAll(tcs.Task, Task.Factory.FromAsync(asyncResult, _dispatchThreadControl.EndInvoke));
Microsoft.AspNetCore.DataProtection (1)
KeyManagement\KeyRingProvider.cs (1)
366existingTask = Task.Factory.StartNew(
Microsoft.AspNetCore.Mvc.Core.Test (2)
Infrastructure\ControllerActionInvokerTest.cs (2)
1899return Task.Factory.StartNew(async () => await Task.Factory.StartNew(() => i));
Microsoft.AspNetCore.OutputCaching.StackExchangeRedis (1)
RedisOutputCacheStore.cs (1)
88_ = Task.Factory.StartNew(RunGarbageCollectionLoopAsync, default, TaskCreationOptions.LongRunning, TaskScheduler.Current);
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.AspNetCore.WebSockets.Tests (1)
BufferStream.cs (1)
288Task.Factory.StartNew(() => _readWaitingForData.TrySetResult());
Microsoft.Build (4)
BackEnd\BuildManager\BuildManager.cs (1)
1489Task.Factory.StartNew(
BackEnd\Components\RequestBuilder\RequestBuilder.cs (3)
653_requestTask = Task.Factory.StartNew( 690_requestTask = Task.Factory.StartNew( 702_requestTask = Task.Factory.StartNew(
Microsoft.Build.Engine.OM.UnitTests (1)
Definition\Project_Tests.cs (1)
354tasks[i] = Task.Factory.StartNew(delegate () { new Project(); }); // Should not throw
Microsoft.CodeAnalysis.CodeStyle (1)
src\Workspaces\SharedUtilitiesAndExtensions\Compiler\Core\Utilities\RoslynParallel.NetFramework.cs (1)
472System.Threading.Tasks.Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);
Microsoft.CodeAnalysis.EditorFeatures (1)
IntelliSense\ModelComputation.cs (1)
122_notifyControllerTask = Task.Factory.ContinueWhenAll(
Microsoft.CodeAnalysis.EditorFeatures.Test.Utilities (1)
Threading\WpfTestRunner.cs (1)
57var task = Task.Factory.StartNew(async () =>
Microsoft.CodeAnalysis.EditorFeatures.UnitTests (3)
Utilities\AsynchronousOperationListenerTests.cs (3)
61task = Task.Factory.StartNew(() => 299var firstTask = Task.Factory.StartNew(() => 309var secondTask = Task.Factory.StartNew(() =>
Microsoft.CodeAnalysis.Workspaces (3)
FindSymbols\SymbolTree\SymbolTreeInfoCacheService.cs (1)
61=> Task.Factory.StartNew(createWorkAsync, cancellationToken, TaskCreationOptions.None, _scheduler).Unwrap();
Storage\SQLite\v2\SQLitePersistentStorage_Threading.cs (1)
24var task = Task.Factory.StartNew(boundFunction, cancellationToken, TaskCreationOptions.None, scheduler);
Workspace\Workspace.cs (1)
746await Task.Factory.StartNew(() =>
Microsoft.CodeAnalysis.Workspaces.UnitTests (1)
UtilityTest\AsyncLazyTests.cs (1)
67Task.Factory.StartNew(() =>
Microsoft.Extensions.Caching.Memory (3)
CacheEntry.CacheEntryTokens.cs (1)
109Task.Factory.StartNew(state => InvokeCallbacks((CacheEntry)state!), cacheEntry,
CacheEntry.cs (1)
283Task.Factory.StartNew(state =>
MemoryCache.cs (1)
397Task.Factory.StartNew(state => ((MemoryCache)state!).ScanForExpiredItems(), this,
Microsoft.Extensions.DependencyInjection (1)
ServiceLookup\StackGuard.cs (1)
68Task<R> task = Task.Factory.StartNew((Func<object?, R>)action, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
Microsoft.Extensions.FileProviders.Physical (1)
PhysicalFilesWatcher.cs (1)
460Task.Factory.StartNew(
Microsoft.VisualBasic.Tests (4)
Microsoft\VisualBasic\ApplicationServices\SingleInstanceTests.cs (4)
105var tasks = Enumerable.Range(0, n).Select(i => Task.Factory.StartNew(() => 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: default, creationOptions: default, scheduler: TaskScheduler.Default); 229var task = Task.Factory.StartNew(() => SendSecondInstanceArgs(pipeName, SendTimeout, ["1", "ABC"]), cancellationToken: default, creationOptions: default, scheduler: TaskScheduler.Default);
Microsoft.VisualStudio.LanguageServices (1)
ProjectSystem\FileChangeWatcherProvider.cs (1)
28var fileChangeService = Task.Factory.StartNew(
OrderProcessor (1)
OrderProcessingWorker.cs (1)
26return Task.Factory.StartNew(async () =>
Roslyn.VisualStudio.DiagnosticsWindow (1)
OptionPages\ForceLowMemoryMode.cs (1)
80return Task.Factory.StartNew(() => this.PopulateAndMonitorWorkerAsync(size), CancellationToken.None, TaskCreationOptions.LongRunning, TaskScheduler.Default).Unwrap();
Security.TransportSecurity.IntegrationTests (2)
Tcp\StreamingTests.4.1.0.cs (2)
393Task.Factory.StartNew(() => StreamingTests.NetTcp_TransportSecurity_Streamed_RoundTrips_String(), CancellationToken.None, TaskCreationOptions.None, TaskScheduler.FromCurrentSynchronizationContext()).Wait(); 412Task.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)
128Task.Factory.StartNew(
System.IO.Pipes (1)
System\IO\Pipes\NamedPipeClientStream.cs (1)
194return Task.Factory.StartNew(static state =>
System.IO.Ports (1)
System\IO\Ports\SerialStream.Unix.cs (1)
683_ioLoop = Task.Factory.StartNew(
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 (1)
System\Linq\Parallel\Scheduling\QueryTask.cs (1)
84return Task.Factory.StartNew(s_baseWorkDelegate, this, CancellationToken.None, TaskCreationOptions.AttachedToParent | TaskCreationOptions.PreferFairness, taskScheduler);
System.Net.Http (1)
System\Net\Http\SocketsHttpHandler\ConnectionPool\HttpConnectionPool.cs (1)
1006Task.Factory.StartNew(static s => ((List<HttpConnectionBase>)s!).ForEach(c => c.Dispose()), toDispose,
System.Net.HttpListener (3)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
368Task.Factory.StartNew(
System\Net\HttpListener.cs (1)
292return Task.Factory.FromAsync(
System\Net\HttpListenerRequest.cs (1)
256return Task.Factory.FromAsync(
System.Net.Mail (1)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
368Task.Factory.StartNew(
System.Net.NetworkInformation (1)
System\Net\NetworkInformation\UnixIPGlobalProperties.cs (1)
54return Task.Factory.StartNew(s => ((UnixIPGlobalProperties)s!).GetUnicastAddresses(), this,
System.Net.Requests (5)
src\libraries\Common\src\System\Net\LazyAsyncResult.cs (1)
368Task.Factory.StartNew(
System\Net\FileWebRequest.cs (4)
160Task<Stream> t = Task.Factory.StartNew<Stream>(s => ((FileWebRequest)s!).CreateWriteStream(), 168return Task.Factory.StartNew<Stream>(s => 221Task<WebResponse> t = Task.Factory.StartNew(s => ((FileWebRequest)s!).CreateResponse(), 229return Task.Factory.StartNew(s =>
System.Private.CoreLib (18)
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 (1)
192Task.Factory.StartNew(
src\libraries\System.Private.CoreLib\src\System\IO\TextWriter.cs (9)
539Task.Factory.StartNew(static state => 546Task.Factory.StartNew(static state => 585Task.Factory.StartNew(static state => 595Task.Factory.StartNew(static state => 602Task.Factory.StartNew(static state => 609Task.Factory.StartNew(static state => 649Task.Factory.StartNew(static state => 659Task.Factory.StartNew(static state => 672return Task.Factory.StartNew(static state => ((TextWriter)state!).Flush(), this,
src\libraries\System.Private.CoreLib\src\System\Runtime\CompilerServices\YieldAwaitable.cs (2)
110Task.Factory.StartNew(continuation, default, TaskCreationOptions.PreferFairness, scheduler); 143Task.Factory.StartNew(static s => ((IAsyncStateMachineBox)s!).MoveNext(), box, default, TaskCreationOptions.PreferFairness, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\CancellationTokenSource.cs (1)
343return Task.Factory.StartNew(s =>
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Sources\ManualResetValueTaskSourceCore.cs (1)
311Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, scheduler);
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\Task.cs (2)
72/// using the Task type's <see cref="Factory"/> property to retrieve a <see 1458/// The factory returned from <see cref="Factory"/> is a default instance
src\libraries\System.Private.CoreLib\src\System\Threading\Tasks\TaskFactory.cs (1)
31/// <see cref="Task.Factory">Task.Factory</see> property.
System.ServiceModel.Federation (7)
System\Runtime\OperationWithTimeoutAsyncResult.cs (1)
25_ = Task.Factory.StartNew(s_scheduledCallback, this, CancellationToken.None, TaskCreationOptions.DenyChildAttach, TaskScheduler.Default);
System\ServiceModel\Federation\WSTrustChannel.cs (1)
361Message response = await Task.Factory.FromAsync(RequestChannel.BeginRequest, RequestChannel.EndRequest, requestMessage, null, TaskCreationOptions.None).ConfigureAwait(false);
System\ServiceModel\Federation\WSTrustChannelSecurityTokenProvider.cs (5)
243await Task.Factory.FromAsync(channel.BeginOpen, channel.EndOpen, null, TaskCreationOptions.None); 247Message reply = await Task.Factory.FromAsync(channel.BeginRequest, channel.EndRequest, requestMessage, null, TaskCreationOptions.None); 254await Task.Factory.FromAsync(channel.BeginClose, channel.EndClose, null, TaskCreationOptions.None); 452await Task.Factory.FromAsync(ChannelFactory.BeginClose, ChannelFactory.EndClose, timeout, null, TaskCreationOptions.None); 469await Task.Factory.FromAsync(channelFactory.BeginOpen, channelFactory.EndOpen, null, TaskCreationOptions.None);
System.ServiceModel.NetFramingBase (4)
System\ServiceModel\Channels\NetFramingTransportChannelFactory.cs (2)
336return Task.Factory.FromAsync(localUpgrade.BeginOpen, localUpgrade.EndOpen, timeout, null); 357await Task.Factory.FromAsync(localUpgrade.BeginClose, localUpgrade.EndClose, timeoutHelper.RemainingTime(), null);
System\ServiceModel\Security\SecurityUtilsEx.cs (2)
92return Task.Factory.FromAsync(co.BeginClose, co.EndClose, timeout, null, TaskCreationOptions.None); 107return Task.Factory.FromAsync(obj.BeginOpen, obj.EndOpen, timeout, null);
System.ServiceModel.Primitives.Tests (7)
Channels\CustomChannelTest.cs (2)
152Task openTask = Task.Factory.FromAsync(openResult, factory.EndOpen); 168Task task = Task.Factory.FromAsync(asyncResult, factory.EndClose);
ServiceModel\ChannelFactoryTest.cs (2)
221Task.Factory.FromAsync(factory.BeginOpen(null, null), factory.EndOpen).GetAwaiter().GetResult(); 225Task.Factory.FromAsync(factory.BeginClose(null, null), factory.EndClose).GetAwaiter().GetResult();
ServiceModel\ThrowingOnCloseBindingElement.cs (3)
79return ToApm(Task.Factory.FromAsync(_innerFactory.BeginOpen, _innerFactory.EndOpen, timeout, null), callback, state); 121await Task.Factory.FromAsync(base.OnBeginClose, base.OnEndClose, timeout, null); 122await Task.Factory.FromAsync(_innerFactory.BeginClose, _innerFactory.EndClose, timeout, null);
System.Threading.Channels (2)
System\Threading\Channels\AsyncOperation.cs (2)
292Task.Factory.StartNew(continuation, state, CancellationToken.None, TaskCreationOptions.DenyChildAttach, ts); 418Task.Factory.StartNew(static s => ((AsyncOperation<TResult>)s!).SetCompletionAndInvokeContinuation(), this,
System.Threading.Tasks.Dataflow (25)
Base\DataflowBlock.cs (7)
511System.Threading.Tasks.Task.Factory.StartNew( 525System.Threading.Tasks.Task.Factory.StartNew( 1290System.Threading.Tasks.Task.Factory.StartNew(static state => 1301System.Threading.Tasks.Task.Factory.StartNew(static state => 1322System.Threading.Tasks.Task.Factory.StartNew(state => 1887task = Task.Factory.StartNew(ChooseTarget<T>.s_processBranchFunction, 1938Task.Factory.ContinueWhenAll(branchTasks, tasks =>
Blocks\BatchBlock.cs (2)
522Task.Factory.StartNew(thisTargetCore => 654Task.Factory.StartNew(exc => Complete(exception: (Exception)exc!, dropPendingMessages: true, releaseReservedMessages: true, revertProcessingState: true),
Blocks\BroadcastBlock.cs (5)
270Task.Factory.StartNew(exc => CompleteCore(exception: (Exception)exc!, storeExceptionEvenIfAlreadyCompleting: true, revertProcessingState: true), 382Task.Factory.StartNew(static state => 640Task.Factory.StartNew(static state => 854Task.Factory.StartNew(static state => 946Task.Factory.StartNew(static thisSourceCore => ((BroadcastingSourceCore<TOutput>)thisSourceCore!).CompleteBlockOncePossible(),
Blocks\BufferBlock.cs (2)
271Task.Factory.StartNew(exc => CompleteCore(exception: (Exception)exc!, storeExceptionEvenIfAlreadyCompleting: true, revertProcessingState: true), 385Task.Factory.StartNew(static state =>
Blocks\JoinBlock.cs (3)
83Task.Factory.ContinueWhenAll( 302Task.Factory.ContinueWhenAll( 1331Task.Factory.StartNew(static state =>
Blocks\WriteOnceBlock.cs (1)
137Task.Factory.StartNew(static state =>
Internal\SourceCore.cs (3)
513Task.Factory.StartNew(static state => 776Task.Factory.StartNew(static state => 919Task.Factory.StartNew(static state => ((SourceCore<TOutput>)state!).CompleteBlockOncePossible(),
Internal\TargetCore.cs (2)
388Task.Factory.StartNew(exc => Complete(exception: (Exception)exc!, dropPendingMessages: true, storeExceptionEvenIfAlreadyCompleting: true, 745Task.Factory.StartNew(static state => ((TargetCore<TInput>)state!).CompleteBlockOncePossible(),
System.Threading.Tasks.Parallel (2)
System\Threading\Tasks\Parallel.cs (1)
340tasks[i] = Task.Factory.StartNew(actionsCopy[i], parallelOptions.CancellationToken, TaskCreationOptions.None,
System\Threading\Tasks\Parallel.ForEachAsync.cs (1)
581Task.Factory.StartNew(_taskBody!, this, default(CancellationToken), TaskCreationOptions.DenyChildAttach, _scheduler);