Project Name File Name Usage Source Code Link
AccelIRC IRCClient.cs new System.Threading.Tasks.Task(() => PingServer()) Link To Source File
AccelIRC IRCClient.cs new System.Threading.Tasks.Task(() => HandleChannelStack()) Link To Source File
AccelIRC IRCEngine.cs new Task(() => RunReader()) Link To Source File
Hex ComputerMoveCalculator.cs new Task(this.DoMove) Link To Source File
eOculus DrawingTests.cs new Task(actions[i]) Link To Source File
ASP.NET-Mvc-3 RazorParser.cs new Task(() => { try { Parse(input, consumer); } catch (OperationCanceledException) { return; // Just return if we're cancelled. } }) Link To Source File
CSC431 Step.cs new Task(() => { Console.WriteLine("top"); s.Process(); }) Link To Source File
CSC431 Program.cs new Task(() => { Options.ParseParameters(args); if (Options.DisplayHelp.Value) Options.WriteOptionDescriptions(Console.Out); else if (Options.DisplayStepGraph.Value) Console.WriteLine(Step.MakeGraph(Options.CreatePipe(null))); else Step.DoAll(Options.CreatePipe(Console.Out)); }) Link To Source File
chocolatey.org LuceneIndexingJob.cs new Task(indexingService.UpdateIndex) Link To Source File
chocolatey.org WorkItemCleanupJob.cs new Task(UpdateStats) Link To Source File
chocolatey.org UpdateStatisticsJob.cs new Task(UpdateStats) Link To Source File
ionfish PicasaImageUploader.cs new Task(() => UploadImageBySendingWebRequest(filename)) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
PSClient CoAppClient.cs new Task(() => { foreach (Runspace R in Remotes) { Task> T = new Task>(() => Remote.Exec(R, com)); T.ContinueWith(antecedent => output.AddRange(antecedent.Result), TaskContinuationOptions.AttachedToParent); T.Start(); } }) Link To Source File
TweetAndPub FeedPivotViewModel.cs new Task(InitDatabase) Link To Source File
TweetAndPub ThreadQueryPool.cs new Task(() => ProcessQueries(session)) Link To Source File
TweetAndPub IntervalContentWriterBase.cs new Task(() => { try { OnInternalBufferClose(bufferedContent); } catch (Exception e) { OnError(e); } finally { bufferedContent.Clear(); BufferedListsQueue.Enqueue(bufferedContent); } }) Link To Source File
TweetAndPub MainViewModel.cs // new Thread(InitDatabase).Start(); new Task(InitDatabase) Link To Source File
TweetAndPub MainPage.xaml.cs new Task(() => OnLoaded(sender, args)) Link To Source File
TweetAndPub AssignmentViewModel.cs new Task(InitDatabase) Link To Source File
TweetAndPub StatusGetter.cs new Task(InitDatabase) Link To Source File
ConcurrentList SaneParallel.cs new Task(() => { Interlocked.Increment(ref _threadCounter); //Thread.Sleep(100); action(local); if (_threadCounter > _maxThreads) Interlocked.CompareExchange(ref _maxThreads, _threadCounter, _maxThreads); Interlocked.Decrement(ref _threadCounter); }) Link To Source File
ConcurrentList SaneParallel.cs new Task(() => { Interlocked.Increment(ref _threadCounter); //Thread.Sleep(100); action(local); if (_threadCounter > _maxThreads) Interlocked.CompareExchange(ref _maxThreads, _threadCounter, _maxThreads); Interlocked.Decrement(ref _threadCounter); }) Link To Source File
SisoDb-Provider ServiceStackJsonSerializer.cs new Task(() => { foreach (var json in sourceData) q.Add(json); q.CompleteAdding(); }) Link To Source File
fubumvc AsyncBehaviorInvokerTester.cs new Task(() => theInvoker.Invoke(theArguments, theRouteData)) Link To Source File
fubumvc ActionCallTester.cs new Task(() => { }) Link To Source File
fubumvc ActionCallTester.cs new Task(() => { LastNameEntered = input.Name; }) Link To Source File
Hazware.Core ActionExtensions.cs new Task(action) Link To Source File
Hazware.Core ActionExtensions.cs new Task(action) Link To Source File
FlameSorceress MainWindowViewModel.cs new Task(model.auth_step1) Link To Source File
FlameSorceress MainWindowViewModel.cs new Task(() => model.auth_step2(PINCode)) Link To Source File
FlameSorceress MainWindowViewModel.cs new Task(() => model.tweet(parameter)) Link To Source File
FlameSorceress MainWindowViewModel.cs new Task(model.doStream) Link To Source File
WeenyMapper TaskRunner.cs new Task(() => { try { action(); callback(); } catch (Exception e) { if (errorCallback == null) { throw; } errorCallback(e); } }) Link To Source File
WeenyMapper TaskRunner.cs new Task(() => { try { var result = action(); callback(result); } catch (Exception e) { if (errorCallback == null) { throw; } errorCallback(e); } }) Link To Source File
MvcPerf RazorParser.cs new Task(() => { try { Parse(input, consumer); } catch (OperationCanceledException) { return; // Just return if we're cancelled. } }) Link To Source File
SharpDevelop XamlColorizer.cs new Task(Process) Link To Source File
Saturnus IndexGeneratorTestsFileSystemEvents.cs new Task( () => { } ) Link To Source File
Saturnus IndexGeneratorTestsFileSystemEvents.cs new Task( () => { } ) Link To Source File
ironfoundry Agent.cs new Task(HeartbeatLoop) Link To Source File
ironfoundry Agent.cs new Task(SnapshotVarz) Link To Source File
ironfoundry Agent.cs new Task(MonitorApps) Link To Source File
ironfoundry DeaWinService.cs new Task(() => agent.Start()) Link To Source File
VsVim AsyncTaggerTest.cs new Task(() => { }) Link To Source File
VsVim AsyncTaggerTest.cs new Task(() => { }) Link To Source File
VsVim AsyncTaggerTest.cs new Task(() => { }) Link To Source File
VsVim AsyncTaggerTest.cs new Task(() => { }) Link To Source File
VsVim AsyncTaggerTest.cs new Task(() => { }) Link To Source File
kayak KayakScheduler.cs new Task(action) Link To Source File
Bricks Server.cs new Task(() => Thread.Sleep(ms)) Link To Source File
lokad-cqrs TapeStorageInitilization.cs new Task(() => { }) Link To Source File
Channel9Downloader CategoriesVM.cs new Task(() => { categories = _categoryRepository.GetCategories(); }) Link To Source File
Channel9Downloader CategoriesVM.cs new Task(() => _categoryRepository.UpdateCategories()) Link To Source File
Channel9Downloader DashboardVM.cs new Task(() => { latestVideos = _rssRepository.GetRssItems(); }) Link To Source File
Channel9Downloader DownloadsVM.cs new Task(() => _downloadManager.Initialize(_settings)) Link To Source File
Channel9Downloader DownloadsVM.cs new Task(() => _downloadManager.UpdateAvailableDownloads()) Link To Source File
Simple.Data BufferedEnumerable.cs new Task(() => enumerable.Iterate(iterator)) Link To Source File
mooege Data.cs new Task(() => asset.RunParser()) Link To Source File
GameServer ConsoleCommand.cs new Task(new Action(inputFunktion)) Link To Source File
GameServer Program.cs new System.Threading.Tasks.Task(oAction) Link To Source File
NuGetGallery LuceneIndexingJob.cs new Task(indexingService.UpdateIndex) Link To Source File
NuGetGallery WorkItemCleanupJob.cs new Task(UpdateStats) Link To Source File
NuGetGallery UpdateStatisticsJob.cs new Task(UpdateStats) Link To Source File
WebBackgrounder WebFarmJobCoordinator.cs new Task(() => { throw e; }) Link To Source File
WebBackgrounder ExceptionJob.cs new Task(() => { throw new InvalidOperationException("This is a test"); }) Link To Source File
WebBackgrounder SampleJob.cs new Task(() => Thread.Sleep(3000)) Link To Source File
WebBackgrounder JobHostFacts.cs new Task(() => { throw new InvalidOperationException("Hey, this is supposed to be shut down!"); }) Link To Source File
WebBackgrounder JobHostFacts.cs new Task(() => host.DoWork(new Task(() => { // Was getting inconsistent results with Thread.Sleep(100) for (int i = 0; i < 100; i++) { Thread.Sleep(1); } }))) Link To Source File
WebBackgrounder JobHostFacts.cs new Task(() => { // Was getting inconsistent results with Thread.Sleep(100) for (int i = 0; i < 100; i++) { Thread.Sleep(1); } }) Link To Source File
WebBackgrounder JobManagerFacts.cs new Task(() => jobDoneEvent.Set()) Link To Source File
WebBackgrounder SchedulerFacts.cs new Task(() => Thread.Sleep(1)) Link To Source File
WCFWeb MediaTypeFormatterTests.cs new Task(() => { }) Link To Source File
OG-DotNet LastResultViewClient.cs new Task(Prepare) Link To Source File
nji NjiApi.cs new Task(() => { try { if (Verbose > 1) Out.WriteLine("Extracting {0} ...", tarball); Ionic.Tar.Extract(tarball, destinationDir); } catch (Exception ex) { throw new NjiException("Error occured while extracting - " + tarball, ex); } }) Link To Source File
nji NjiApi.cs new Task(() => { }) Link To Source File
budget Program.cs new Task(Connect) Link To Source File
ravendb IndexCreation.cs new Task(() => Task.WaitAll(array)) Link To Source File
RS-TV-Show-Tracker DownloadLinkSearch.cs new Task(() => SearchEngines.ForEach(engine => engine.CancelAsync())) Link To Source File
RS-TV-Show-Tracker RecommendationEngine.cs new Task(() => { try { var list = GetList(shows); RecommendationDone.Fire(this, list.ToList()); } catch (Exception ex) { RecommendationError.Fire(this, "There was an error while getting the recommendations. Try again later.", ex); } }) Link To Source File
RS-TV-Show-Tracker SubtitleSearch.cs new Task(() => SearchEngines.ForEach(engine => engine.CancelAsync())) Link To Source File
RS-TV-Show-Tracker MainWindow.xaml.cs new Task(() => { try { API.ReportError(ex); } catch { } }) Link To Source File
PROMPT11-07-ConcurrentProgramming.sandrapatfer FileFinderForm.cs new Task(() => { // Parallel.ForEach(Directory.EnumerateDirectories(fldr, "*", SearchOption.AllDirectories), // (dir) => // foreach (var dir in Directory.EnumerateDirectories(fldr, "*", SearchOption.AllDirectories)) // { // if (!_canceled) // { Parallel.ForEach(Directory.EnumerateFiles(fldr, patt, SearchOption.AllDirectories), /*new ParallelOptions() { MaxDegreeOfParallelism = 16 * Environment.ProcessorCount },*/ () => 0, (fname, s, curr) => { if (!_canceled) { string content = File.ReadAllText(fname); if (content.Contains(word)) { ctx.Post((o) => { txtResults.AddLine(fname); }, null); //Interlocked.Increment(ref nFiles); return ++curr; } else { return curr; } } else { return curr; } }, (curr) => { Interlocked.Add(ref nFiles, curr); }); // } // }); // } }) Link To Source File
Picasso LogWriter.cs new Task(mWriteLog) Link To Source File
Picasso MainWindow.cs new System.Threading.Tasks.Task(A) Link To Source File
OpenStory QueueScheduler.cs new Task(action) Link To Source File
Merchant-Editor ItemRow.xaml.cs new Task(() => Thread.Sleep(250)) Link To Source File
spring-net-amqp SimpleMessageListenerContainer.cs new Task(processor.Run) Link To Source File
spring-net-amqp SimpleMessageListenerContainer.cs new Task(processor.Run) Link To Source File
StatLight InMemoryWebServer.cs new Task(ServeRequests) Link To Source File
ScoobyRom MainWindow.cs new Task (() => LoadRomTask (path)) Link To Source File
ScoobyRom DataView2DModelGtk.cs new Task (() => CreateAllIcons ()) Link To Source File
ScoobyRom DataView3DModelGtk.cs new Task (() => CreateAllIcons ()) Link To Source File
twdc RazorParser.cs new Task(() => { try { Parse(input, consumer); } catch (OperationCanceledException) { return; // Just return if we're cancelled. } }) Link To Source File
WebTyphoon WebSocketHandshaker.cs new Task(HandshakeAction) Link To Source File
Rob.DataDemo frmDataTransfer.cs new Task(() => currentReader.executeBulkCopy(initialConnString, workingDatabase)) Link To Source File
dwarrowdelf AStar.cs new Task(delegate { resForward = Find(environment, src, DirectionSet.Exact, dst, dstPositioning, 200000, cts.Token); }) Link To Source File
dwarrowdelf AStar.cs new Task(delegate { resBackward = Find(environment, dst, dstPositioning, src, DirectionSet.Exact, 200000, cts.Token); }) Link To Source File
dwarrowdelf AStar.cs new Task(delegate { rf = Find(environment, src, DirectionSet.Exact, dest, positioning, 200000, cts.Token); }) Link To Source File
dwarrowdelf AStar.cs new Task(delegate { rb = Find(environment, dest, positioning, src, DirectionSet.Exact, 200000, cts.Token); }) Link To Source File
ORTS Engine.cs new Task(() => Sound.Start(this)) Link To Source File
ORTS AsyncObservableTimer.cs new Task(() => base.Start()) Link To Source File
ORTS_mk2 AsyncObservableTimer.cs new Task(() => base.Start()) Link To Source File
SharpEngine GameEngine.cs new Task(() => Audio.Start()) Link To Source File
SharpEngine GameEngine.cs new Task(() => Physics.Start()) Link To Source File
SharpEngine AsyncObservableTimer.cs new Task(() => base.Start()) Link To Source File
WCell TaskSchedulerExtensions.cs new Task(() => d(state)) Link To Source File