Detailed introduction to the basics of .NET parallelism and multi-threading learning

迷茫
Release: 2017-03-26 16:38:18
Original
1229 people have browsed it

1. Parallel initial test:

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");
            }
        }
Copy after login

Call:

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");
}
Copy after login

2. Partition parallelism:

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;
            });
Copy after login

3. Exception catching: 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);
                }
            }
Copy after login

4. Specify parallel scheduling:

ParallelOptions options = new ParallelOptions();
            options.MaxDegreeOfParallelism = 1;//如果设置为1就类似于串行代码按顺序执行
            options.MaxDegreeOfParallelism =Environment.ProcessorCount;//获取计算机上面的处理器数量
            Parallel.For(1,10,options,(x) =>
            {
                Console.WriteLine(x);
            });
Copy after login

The above is the detailed content of Detailed introduction to the basics of .NET parallelism and multi-threading learning. For more information, please follow other related articles on the PHP Chinese website!

Related labels:
source:php.cn
Statement of this Website
The content of this article is voluntarily contributed by netizens, and the copyright belongs to the original author. This site does not assume corresponding legal responsibility. If you find any content suspected of plagiarism or infringement, please contact admin@php.cn
Popular Tutorials
More>
Latest Downloads
More>
Web Effects
Website Source Code
Website Materials
Front End Template