Project Name File Name Usage Source Code Link
soundfingerprinting RepositoryGateway.cs Task.Factory.StartNew(() => { try { tracks = ProcessFiles(files, trackProcessed); callback.Invoke(tracks, null); } catch (AggregateException ex) /*here we are sure all consumers are done processing*/ { callback.Invoke(null, null); _repository.ClearStorage(); /*its safe to clear the storage, no more thread is executing*/ } catch (Exception ex) { callback.Invoke(tracks, ex); } }, _cts.Token) Link To Source File
soundfingerprinting RepositoryGateway.cs Task.Factory.StartNew( () => { foreach (Tuple tuple in buffer.GetConsumingEnumerable()) /*If OCE is thrown it will be caught in the caller's AggregateException*/ { if (tuple != null) { /*Long running procedure*/ _repository.CreateInsertFingerprints(tuple.Item2, tuple.Item1, _createStride, NUMBER_OF_HASH_TABLES, NUMBER_OF_KEYS); processedtracks.Add(tuple.Item1); if (processed != null) processed.Invoke(tuple.Item1); } } }, token) Link To Source File
AccelIRC IdentManager.cs Task.Factory.StartNew(() => HandleIdentRequest(ct.Token), ct.Token) Link To Source File
ASP.NET-Mvc-3 RazorEditorParser.cs Task.Factory.StartNew(() => { try { Interlocked.Increment(ref _activeTaskCount); parser.ProcessChange(token, change, parseTree); } catch (OperationCanceledException) { } #if DEBUG catch (Exception ex) { if (Debugger.IsAttached) { throw; } Debug.Fail("Unexpected exception thrown by parser task", ex.ToString()); } #else catch (Exception) { } #endif }, token) Link To Source File
c-raft Client.Recv.cs Task.Factory.StartNew(() => _player.UpdateChunks(ChraftConfig.SightRadius, token), token) Link To Source File
c-raft Server.cs Task.Factory.StartNew(()=> SavePlayers(50, token), token) Link To Source File
c-raft WorldManager.cs Task.Factory.StartNew(() => SaveProc(chunksToSave, token), token) Link To Source File
coapp EngineService.cs Task.Factory.StartNew(() => { _pipeSecurity = new PipeSecurity(); _pipeSecurity.AddAccessRule(new PipeAccessRule(new SecurityIdentifier(WellKnownSidType.WorldSid,null ), PipeAccessRights.ReadWrite, AccessControlType.Allow)); _pipeSecurity.AddAccessRule(new PipeAccessRule(WindowsIdentity.GetCurrent().Owner, PipeAccessRights.FullControl, AccessControlType.Allow)); // start a few listeners by default--each listener will also spawn a new empty one. StartListener(); StartListener(); StartListener(); StartListener(); StartListener(); StartListener(); }, _cancellationTokenSource.Token) Link To Source File
coapp Session.cs Task.Factory.StartNew(ProcessMesages, _cancellationTokenSource.Token) Link To Source File
_toolkit_deprecated EngineService.cs Task.Factory.StartNew(() => { _pipeSecurity = new PipeSecurity(); _pipeSecurity.AddAccessRule(new PipeAccessRule(new SecurityIdentifier(WellKnownSidType.WorldSid,null ), PipeAccessRights.ReadWrite, AccessControlType.Allow)); _pipeSecurity.AddAccessRule(new PipeAccessRule(WindowsIdentity.GetCurrent().Owner, PipeAccessRights.FullControl, AccessControlType.Allow)); // start a few listeners by default--each listener will also spawn a new empty one. StartListener(); StartListener(); StartListener(); StartListener(); StartListener(); StartListener(); }, _cancellationTokenSource.Token) Link To Source File
_toolkit_deprecated Session.cs Task.Factory.StartNew(ProcessMesages, _cancellationTokenSource.Token) Link To Source File
MvcPerf RazorEditorParser.cs Task.Factory.StartNew(() => { try { Interlocked.Increment(ref _activeTaskCount); parser.ProcessChange(token, change, parseTree); } catch (OperationCanceledException) { } #if DEBUG catch (Exception ex) { if (Debugger.IsAttached) { throw; } Debug.Fail("Unexpected exception thrown by parser task", ex.ToString()); } #else catch (Exception) { } #endif }, token) Link To Source File
CrossWord CrossWordProgram.cs Task.Factory.StartNew(() => { if (gen.Generate()) { successFullBoard = gen.Board; cts.Cancel(); mre.Set(); } }, cts.Token) Link To Source File
Bricks TcpSocket.cs Task.Factory.StartNew(this.ReceiveTask, _tasksHandler.Token) Link To Source File
lokad-cqrs StreamingTimerService.cs Task.Factory.StartNew(() => RunScheduler(token), token) Link To Source File
lokad-cqrs DispatcherProcess.cs Task.Factory.StartNew(() => { try { ReceiveMessages(token); } catch(ObjectDisposedException) { // suppress } }, token) Link To Source File
lokad-cqrs MessageDuplicationManager.cs Task.Factory.StartNew(() => { while (!token.IsCancellationRequested) { foreach (var memory in _memories) { memory.Value.ForgetOlderThan(TimeSpan.FromMinutes(20)); } token.WaitHandle.WaitOne(TimeSpan.FromMinutes(5)); } }, token) Link To Source File
lokad-cqrs ShellServices.cs Task.Factory.StartNew(() => { while (!_source.Token.IsCancellationRequested) { string result; var builder = new StringBuilder(); while (_log.TryDequeue(out result)) { builder.AppendLine(result); } if (builder.Length > 0) { box.Invoke(new Action(() => { box.AppendText(builder.ToString()); box.ScrollToCaret(); })); } _source.Token.WaitHandle.WaitOne(TimeSpan.FromMilliseconds(250)); } }, _source.Token) Link To Source File
lokad-cqrs-samples NHibernateStarter.cs Task.Factory.StartNew(() => { }, token) Link To Source File
Qupla HttpServer.cs Task.Factory.StartNew(StartListener, _cancellationToken) Link To Source File
Qupla HttpServer.cs Task.Factory.StartNew(() => _handleRequestCallback(context), _cancellationToken) Link To Source File
Phutball PhutballGameState.cs Task.Factory.StartNew(() => _bestMoveApplier.ChooseAndPerform(token), token) Link To Source File
nSt.Scorpio PollingSensor.cs Task.Factory.StartNew(() => { try { for (; ; ) { TSensorValue value; if (GetValue(out value)) sensorValues.Add(value); Thread.Sleep(TimeResolution); cancellation.Token.ThrowIfCancellationRequested(); } } catch (OperationCanceledException) { Debug.WriteLine(Name + " sensor values retrieving task interrupted."); } catch (Exception ex) { Debug.WriteLine(string.Format("{0}/n{1}", ex.Message, ex.Source)); } }, cancellation.Token) Link To Source File
Disruptor-net UniCast1P1CBlockingCollectionPerfTest.cs Task.Factory.StartNew(_queueEventProcessor.Run, cts.Token) Link To Source File
Genesis InternalImporter.cs Task.Factory .StartNew(Import, cancellationToken) Link To Source File
Roger With_rabbitmq_broker.cs Task.Factory.StartNew(function, tokenSource.Token) Link To Source File
spring-net-amqp RabbitBrokerAdmin.cs Task.Factory.StartNew( () => { try { if (running.CurrentCount > 0) running.Signal(); var process = Process.Start(execute); process.WaitForExit(); var exit = process.ExitCode; finished = true; logger.Info("Finished broker launcher process with exit code=" + exit); if (exit != 0) { throw new Exception("Could not start process." + errorHint); } } catch (Exception e) { logger.Error("Failed to start node", e); } }, token) Link To Source File
twdc RazorEditorParser.cs Task.Factory.StartNew(() => { try { Interlocked.Increment(ref _activeTaskCount); parser.ProcessChange(token, change, parseTree); } catch (OperationCanceledException) { } #if DEBUG catch (Exception ex) { if (Debugger.IsAttached) { throw; } Debug.Fail("Unexpected exception thrown by parser task", ex.ToString()); } #else catch (Exception) { } #endif }, token) Link To Source File
Disruptor.NET Pipeline3StepLatencyPerfTest.cs Task.Factory.StartNew(stepOneQueueConsumer.Run, ct) Link To Source File
Disruptor.NET Pipeline3StepLatencyPerfTest.cs Task.Factory.StartNew(stepTwoQueueConsumer.Run, ct) Link To Source File
Disruptor.NET Pipeline3StepLatencyPerfTest.cs Task.Factory.StartNew(stepThreeQueueConsumer.Run, ct) Link To Source File
Disruptor.NET Pipeline3StepPerfTest.cs Task.Factory.StartNew(stepOneQueueConsumer.Run, ct) Link To Source File
Disruptor.NET Pipeline3StepPerfTest.cs Task.Factory.StartNew(stepTwoQueueConsumer.Run, ct) Link To Source File
Disruptor.NET Pipeline3StepPerfTest.cs Task.Factory.StartNew(stepThreeQueueConsumer.Run, ct) Link To Source File
RtStorage Player.cs Task.Factory.StartNew(Run, _cancellation.Token) Link To Source File