c# 异步编程学习笔记

Posted 2022-01-12 jjhua

静下心学学await async，越看摊子铺的越大，记录一下。

1、Parallel并行任务

Parallel.For 

Parallel.Foreach

并行同时执行

Parallel.For(0, 100, i =>
     
         Console.WriteLine(i);
     );

输出顺序是不连续的

如果在执行过程中不涉及全局或本方法中的局部变量写操作，执行效率高于普通for和foreach

            stopWatch.Start();
            foreach (var item in _bCollection)
            
                item.Id = _aCollection.FirstOrDefault(x => x.Id == item.Name).Id;
            ;
            stopWatch.Stop();
            Console.WriteLine("NormalFor run " + stopWatch.ElapsedMilliseconds + "     ms.");

            stopWatch.Reset();
            stopWatch.Start();
            Parallel.ForEach(_bCollection, (item) =>
            
                item.Id = _aCollection.FirstOrDefault(x => x.Id == item.Name).Id;
            );
            stopWatch.Stop();
            Console.WriteLine("ParallelFor run " + stopWatch.ElapsedMilliseconds + " ms.");

其中_aCollection定义为100万个元素的集合，_bCollection拥有10万个元素（顺便插一句，对加起来110万的集合初始化普通代码执行真快，没感觉）

输出结果：

NormalFor run 97958 ms.
ParallelFor run 25716 ms.

但是，如果涉及到全局或局部变量（非Parallel中定义）写操作，就需要加lock锁，会影响执行效率

         public void ParallelForMethod()
         
            var obj = new Object();
            long num = 0;
            ConcurrentBag<long> bag = new ConcurrentBag<long>();

            stopWatch.Start();
            for (int i = 0; i < 10000; i++)
            
               for (int j = 0; j < 60000; j++)
               
                  //int sum = 0;
                  //sum += item;
                  num++;
               
            
            stopWatch.Stop();
            Console.WriteLine("NormalFor run " + stopWatch.ElapsedMilliseconds + " ms.");

            stopWatch.Reset();
            stopWatch.Start();
            Parallel.For(0, 10000, item =>
            
               for (int j = 0; j < 60000; j++)
               
                  //int sum = 0;
                  //sum += item;
                  lock (obj)
                  
                     num++;
                  
               
            );
            stopWatch.Stop();
            Console.WriteLine("ParallelFor run " + stopWatch.ElapsedMilliseconds + " ms.");
           
         

输出结果：

NormalFor run 1577 ms.
ParallelFor run 15057 ms.

因此，可以认为，Parallel可以用于量级较大的数组循环操作，同时不考虑执行顺序，写操作只涉及数组元素赋值的情况。

参考文章：5天玩转C#并行和多线程编程 —— 第一天 认识Parallel

Linq中也提供了并行方式： AsParallel

参考文章：5天玩转C#并行和多线程编程 —— 第二天 并行集合和PLinq

2、Task

Task使用线程池实现多线程编程

无返回值常用两种创建方式

        var task1 = new Task(() =>
         
            Console.WriteLine("Hello,task");
         );
         task1.Start();

         var task2 = Task.Factory.StartNew(() =>
         
            Console.WriteLine("Hello,task started by task factory");
         );

StartNew直接启动运行，无需Start

参考文章：

5天玩转C#并行和多线程编程 —— 第三天 认识和使用Task

5天玩转C#并行和多线程编程 —— 第四天 Task进阶

C# Task详解

Task在Winform上简单的应用示例 

3、Await async

C＃ await 高级用法