Project Name File Name Usage Source Code Link
Symbiote RingBuffer.cs Task.Factory.StartNew( () => Process( f.Item1, f.Item2 ), TaskCreationOptions.LongRunning ) Link To Source File
sshnet ChannelDirectTcpip.NET40.cs Task.Factory.StartNew(action, TaskCreationOptions.LongRunning) Link To Source File
sshnet Session.NET40.cs Task.Factory.StartNew(action, TaskCreationOptions.LongRunning) Link To Source File
Fibrous AsyncReqReplyClient.cs Task.Factory.StartNew(Run, TaskCreationOptions.LongRunning) Link To Source File
Fibrous AsyncReqReplyService.cs Task.Factory.StartNew(Run, TaskCreationOptions.LongRunning) Link To Source File
Fibrous AsyncReqReplyService2.cs Task.Factory.StartNew(Run, TaskCreationOptions.LongRunning) Link To Source File
Fibrous AsyncReqReplyClient2.cs Task.Factory.StartNew(Run, TaskCreationOptions.LongRunning) Link To Source File
Fibrous temp.cs Task.Factory.StartNew(Run, TaskCreationOptions.LongRunning) Link To Source File
coapp NewPackageManager.cs Task.Factory.StartNew(() => { if (messages != null) { messages.Register(); } if (CancellationRequested) { PackageManagerMessages.Invoke.OperationCancelled("remove-feed"); return; } // Note: This may need better lookup/matching for the location // as location can be a fuzzy match. if (session ?? false) { // session feed specfied if (!PackageManagerSession.Invoke.CheckForPermission(PermissionPolicy.EditSessionFeeds)) { PackageManagerMessages.Invoke.PermissionRequired("EditSessionFeeds"); return; } RemoveSessionFeed(location); PackageManagerMessages.Invoke.FeedRemoved(location); } else { // system feed specified if (!PackageManagerSession.Invoke.CheckForPermission(PermissionPolicy.EditSystemFeeds)) { PackageManagerMessages.Invoke.PermissionRequired("EditSystemFeeds"); return; } RemoveSystemFeed(location); PackageManagerMessages.Invoke.FeedRemoved(location); } }, TaskCreationOptions.AttachedToParent) Link To Source File
_toolkit_deprecated NewPackageManager.cs Task.Factory.StartNew(() => { if (messages != null) { messages.Register(); } if (CancellationRequested) { PackageManagerMessages.Invoke.OperationCancelled("remove-feed"); return; } // Note: This may need better lookup/matching for the location // as location can be a fuzzy match. if (session ?? false) { // session feed specfied if (!PackageManagerSession.Invoke.CheckForPermission(PermissionPolicy.EditSessionFeeds)) { PackageManagerMessages.Invoke.PermissionRequired("EditSessionFeeds"); return; } RemoveSessionFeed(location); PackageManagerMessages.Invoke.FeedRemoved(location); } else { // system feed specified if (!PackageManagerSession.Invoke.CheckForPermission(PermissionPolicy.EditSystemFeeds)) { PackageManagerMessages.Invoke.PermissionRequired("EditSystemFeeds"); return; } RemoveSystemFeed(location); PackageManagerMessages.Invoke.FeedRemoved(location); } }, TaskCreationOptions.AttachedToParent) Link To Source File
localtunnel-net-client ChannelDirectTcpip.NET40.cs Task.Factory.StartNew(action, TaskCreationOptions.LongRunning) Link To Source File
localtunnel-net-client Session.NET40.cs Task.Factory.StartNew(action, TaskCreationOptions.LongRunning) Link To Source File
fubumvc AsyncInterceptExceptionBehavior.cs Task.Factory.StartNew(() => InsideBehavior.Invoke(), TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc AsyncBehaviorInvoker.cs Task.Factory.StartNew(behavior.Invoke, TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc SleepController.cs Task.Factory.StartNew(() => Thread.Sleep(100), TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc AsyncInterceptExceptionBehaviorTester.cs Task.Factory.StartNew(() => { throw _exception; }, TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc AsyncInterceptExceptionBehaviorTester.cs Task.Factory.StartNew(() => { throw _exception; }, TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc AsyncInterceptExceptionBehaviorTester.cs Task.Factory.StartNew(() => { }, TaskCreationOptions.AttachedToParent) Link To Source File
fubumvc AsyncInterceptExceptionBehaviorTester.cs Task.Factory.StartNew(() => { }, TaskCreationOptions.AttachedToParent) Link To Source File
Mystique FollowManagerViewModel.cs Task.Factory.StartNew(() => { UserInformationManager.ReceiveInidividualInfo(Info); DispatcherHelper.BeginInvoke(()=> { IsStandby = true; RefreshUserData(); }); }, TaskCreationOptions.LongRunning) Link To Source File
MSTest MessageProcessorWithCustomBlockingQueue.cs Task.Factory.StartNew(() => Dispatch(new MessageBuilder(threadsCount, messagesCount, temp).GetMessages(), temp), TaskCreationOptions.LongRunning) Link To Source File
SuperSocket Async.cs Task.Factory.StartNew(task, taskOption) Link To Source File
SuperSocket MainViewModel.cs Task.Factory.StartNew(ProcessSendWorker, TaskCreationOptions.LongRunning) Link To Source File
SuperSocket Async.cs Task.Factory.StartNew(task, taskOption) Link To Source File
SwarmIntelligence LogManager.cs Task.Factory.StartNew( () => logJournal.NotifyRecordsAdded(newRecords, lastOldRecord + 1, lastNewRecord), TaskCreationOptions.LongRunning | TaskCreationOptions.PreferFairness) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { throw new Exception("Child faulting."); }, TaskCreationOptions.AttachedToParent) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { throw new Exception(string.Format("Child {0} faulting.", x)); }, TaskCreationOptions.AttachedToParent) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { for (int j = 0; j < 2; j++) { int y = j; Task.Factory.StartNew(() => { throw new Exception(string.Format("Grandchild {0} faulting.",y)); }, TaskCreationOptions.AttachedToParent); } throw new Exception(string.Format("Child {0} faulting", x)); }, TaskCreationOptions.AttachedToParent) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { throw new Exception(string.Format("Grandchild {0} faulting.",y)); }, TaskCreationOptions.AttachedToParent) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { throw new Exception("Child faulting."); }, TaskCreationOptions.AttachedToParent) Link To Source File
preprompt-parallel Exceptions.cs Task.Factory.StartNew(() => { throw new Exception("Child faulting."); }, TaskCreationOptions.AttachedToParent) Link To Source File
ravendb AbstractBackgroundTask.cs Task.Factory.StartNew(BackgroundTask,TaskCreationOptions.LongRunning) Link To Source File
NServieBus.Xms MessagePubliher.cs factory.StartNew(() => PublishUsingSingleThread(perThread), options) Link To Source File
AzureMultiEntitySchema CommandHandler.cs Task.Factory.StartNew( () => { while (true) { this.Cycle(command); } }, TaskCreationOptions.LongRunning) Link To Source File
AzureMultiEntitySchema BatchQueueCommandHandler.cs Task.Factory.StartNew( () => { while (true) { this.Cycle(batchQueueCommand); } }, TaskCreationOptions.LongRunning) Link To Source File
AzureMultiEntitySchema QueueCommandHandler.cs Task.Factory.StartNew( () => { while (true) { Cycle(queueCommand); } }, TaskCreationOptions.LongRunning) Link To Source File
Roger DefaultConsumingProcess.cs Task.Factory.StartNew(ConsumeSynchronously, TaskCreationOptions.LongRunning) Link To Source File
Roger QueueingPublishingProcess.cs Task.Factory.StartNew(() => { try { foreach (var factory in publishingQueue.GetConsumingEnumerable(tokenSource.Token)) { try { publishEnabled.Wait(tokenSource.Token); } catch (OperationCanceledException) { // operation canceled while waiting for publish to be enabled, just break out of the loop break; } var delivery = factory.Create(model, idGenerator, typeResolver, serializer, sequenceGenerator); log.Debug("Executing delivery"); try { delivery.Execute(model, endpoint, modules); } /* * we may experience a newtork problem even before the connection notifies its own shutdown * but it's safer not to disable publishing to avoid the risk of deadlocking * Instead we catch the exception and hopefully will republish these messages */ catch (AlreadyClosedException e) { log.Error("Model was already closed when trying to publish on it", e); } catch (IOException e) { log.Error("IO error when trying to publish", e); } } } catch (OperationCanceledException) { // operation canceled while iterating over the queue, do nothing and let task complete } catch (ObjectDisposedException) { log.Error("Publishing queue was disposed while iterating over it, this is not supposed to be happening"); } }, TaskCreationOptions.LongRunning) Link To Source File
snippets TPLTests.cs Task.Factory.StartNew(() => { Thread.SpinWait(50000); Console.WriteLine("Attached child completed."); }, TaskCreationOptions.AttachedToParent) Link To Source File
Demotic Server.cs Task.Factory.StartNew(() => AcceptLoop(p), TaskCreationOptions.LongRunning) Link To Source File