public static void test() { for (int i = 0; i < 10000; i++) { Console.WriteLine(i); } } public static void test1() { for (int i = 0; i < 10000; i++) { Console.WriteLine(i + "aaaaaaaaaaaaaaa"); } }
挪用:
static void Main(string[] args) { Stopwatch sw = new Stopwatch(); sw.Start(); //串行实行: test(); test1(); //并行实行: 17Parallel.Invoke(test, test1); 19sw.Stop(); 21Console.WriteLine("共消耗时候:"); 23Console.WriteLine(sw.ElapsedMilliseconds / 1000+"s"); }
二、分区并行:
Parallel.ForEach(Partitioner.Create(1,20,5),(x,s)=>{ //并行代码中自定义串行,第三个参数示意item1到item2之间的局限 Console.WriteLine(x); for (int i = x.Item1; i < x.Item2; i++) { if (i == 10) break; Console.WriteLine(i); } s.Break();// 非常相似一般for循环中的break if (s.ShouldExitCurrentIteration) return; });
三、非常捕捉:AggregateException
int[] arry = new int[10001]; for (int i = 0; i < 10000; i++) { arry[i] = i; } try { Parallel.ForEach(arry, (x, s) => { Console.WriteLine(x); if (sw.Elapsed.Seconds > 3) { throw new TimeoutException("操纵超时"); } }); } catch (AggregateException ex) { foreach (var item in ex.InnerExceptions) { Console.WriteLine(item); } }
四、指定并行调理:
ParallelOptions options = new ParallelOptions(); options.MaxDegreeOfParallelism = 1;//假如设置为1就相似于串行代码按递次实行 options.MaxDegreeOfParallelism =Environment.ProcessorCount;//猎取盘算机上面的处理器数目 Parallel.For(1,10,options,(x) => { Console.WriteLine(x); });
以上就是细致引见.NET并行与多线程进修基本的细致内容,更多请关注ki4网别的相干文章!