Project Name File Name Usage Source Code Link
lucene.net SimpleFacetedSearch.cs Parallel.Invoke(actions) Link To Source File
Symbiote Class1.cs Parallel.Invoke(action, action, action, action) Link To Source File
nCQRS AggregateRootTests.cs System.Threading.Tasks.Parallel.Invoke( registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot) Link To Source File
Super2013 AggregateRootTests.cs System.Threading.Tasks.Parallel.Invoke( registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot) Link To Source File
Kinect SemaphoreGesture.cs Parallel.Invoke( () => leftAngle = Calculator.CalculateAngle(leftHand.X, leftHand.Y, leftBody.X, leftBody.Y), () => rightAngle = Calculator.CalculateAngle(rightHand.X, rightHand.Y, rightBody.X, rightBody.Y)) Link To Source File
Fracture ParallelInvoker.cs #if XBOX foreach (var d in Delegates) ThreadPool.AddTask(d, null, null); WaitHandle.WaitAll(Signals); #else Parallel.Invoke(Delegates) Link To Source File
Fracture RenderManager.cs #if XBOX for (int i = 0; i < _WorkerThreads.Length; i++) { var wt = _WorkerThreads[i]; wt.WaitForPendingWork(); var info = wt.Tag as WorkerThreadInfo; lock (info) { if (info.Frame != null) throw new InvalidOperationException(); } } #else System.Threading.Tasks.Parallel.Invoke( new System.Threading.Tasks.ParallelOptions { MaxDegreeOfParallelism = _WorkerInfo.Length }, _WorkerDelegates ) Link To Source File
Algorithms SpinLockDemo.cs Parallel.Invoke( () => { for (int i = 0; i < N; i++) { UpdateWithSpinLock(new Data() { Name = i.ToString(), Number = i }, i); } }, () => { for (int i = 0; i < N; i++) { UpdateWithSpinLock(new Data() { Name = i.ToString(), Number = i }, i); } } ) Link To Source File
Algorithms SpinLockDemo.cs Parallel.Invoke( () => { for (int i = 0; i < N; i++) { UpdateWithLock(new Data() { Name = i.ToString(), Number = i }, i); } }, () => { for (int i = 0; i < N; i++) { UpdateWithLock(new Data() { Name = i.ToString(), Number = i }, i); } } ) Link To Source File
Algorithms ThreadSafeList.cs Parallel.Invoke(()=>Adding(),()=>Removing()) Link To Source File
EasyNetQ ThreadLocalSpike.cs Parallel.Invoke(action, action, action, action, action, action, action, action) Link To Source File
ncqrs AggregateRootTests.cs System.Threading.Tasks.Parallel.Invoke( registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot, registerOneCallbackOnAggregateRoot, registerTwoCallbacksOnAggregateRoot) Link To Source File
pengine AssetsManager.cs Parallel.Invoke(() => { asset = pool.Load(assetName); var gi = asset as GraphicsAsset; if (gi != null) { _graphicsResources.Enqueue(gi); } _assetsCurrentlyLoading--; } //close third Action ) Link To Source File
bbwifimusicsync MainWindow.xaml.cs Parallel.Invoke(() => { viewModelSync.LoadPlaylists(); Log.Info("Playlists loaded."); viewModelSync.LoadDrives(viewModelSync.ShowAllDrives); Log.Info("Drives loaded. " + viewModelSync.Drives.Count + " drives found."); }) Link To Source File
snippets TaskParallelism.cs // Perform three tasks in parallel on the source array Parallel.Invoke(() => { Console.WriteLine("Begin first task on {0}...", Thread.CurrentThread.ManagedThreadId); GetLongestWord(words); }, // close first Action () => { Console.WriteLine("Begin second task on {0}...", Thread.CurrentThread.ManagedThreadId); GetMostCommonWords(words); }, //close second Action () => { Console.WriteLine("Begin third task on {0}...", Thread.CurrentThread.ManagedThreadId); GetCountForWord(words, "species"); } //close third Action ) Link To Source File
Rob.DataDemo ParallelWrapper.cs Parallel.Invoke(actions.Select(action => new Action(() => { try { action(); } catch (Exception ex) { exceptions.Enqueue(ex); } })).ToArray()) Link To Source File
Homework.PatentApplicationSystem WorkflowTest.cs Parallel.Invoke(() => 办案(@case.编号, 主办员, TaskNames.撰写五书) .Should().BeTrue(), () => { 办案(@case.编号, 一校, TaskNames.原始资料翻译一校) .Should().BeFalse(); 办案(@case.编号, 翻译, TaskNames.原始资料翻译) .Should().BeTrue(); 办案(@case.编号, 二校, TaskNames.原始资料翻译二校) .Should().BeFalse(); 办案(@case.编号, 一校, TaskNames.原始资料翻译一校) .Should().BeTrue(); 办案(@case.编号, 二校, TaskNames.原始资料翻译二校) .Should().BeTrue(); }) Link To Source File
Homework.PatentApplicationSystem WorkflowTest.cs // 并行处理10个案件案件 Parallel.Invoke(() => 客户指示处理测试(new Case { 编号 = "111", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.客户指示处理 }, 办案员B), () => 客户指示处理测试(new Case { 编号 = "222", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.客户指示处理 }, 办案员B), () => 客户指示处理测试(new Case { 编号 = "333", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.客户指示处理 }, 办案员A), () => 新申请测试(new Case { 编号 = "444", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.新申请 }, 办案员A, 办案员B, 办案员A, 办案员C), () => 新申请测试(new Case { 编号 = "555", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.新申请 }, 办案员A, 办案员B, 办案员A, 办案员C), () => 新申请测试(new Case { 编号 = "666", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.新申请 }, 办案员A, 办案员A, 办案员B, 办案员C), () => 新申请测试(new Case { 编号 = "777", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.新申请 }, 办案员A, 办案员C, 办案员B, 办案员A), () => 官方来函测试(new Case { 编号 = "888", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.官方来函 }, 办案员C), () => 官方来函测试(new Case { 编号 = "999", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.官方来函 }, 办案员B), () => 官方来函测试(new Case { 编号 = "000", 创建时间 = DateTime.Now, 绝限日 = DateTime.Now.AddDays(30), 案件类型 = CaseType.官方来函 }, 办案员B)) Link To Source File
lucene.net SimpleFacetedSearch.cs Parallel.Invoke(actions) Link To Source File
GpxViewer Controller.cs Parallel.Invoke(() => { i.ImportGPX(Ordner_Browser, null); } ) Link To Source File
GpxViewer Controller.cs Parallel.Invoke(() => { i.ImportGPX(null, GPXFile); } ) Link To Source File