zoukankan      html  css  js  c++  java
  • C# Parallel.ForEach与foreach的使用

      我们循环大多数是用的foreach,这种方法是串行,也就是单线程,而Parallel.ForEach指的是并行,也就是多线程。

      在循环迭代时,并不是用并行时间越短,下面是一个测试实例,分别用串行和并行循环150W条数据

    using System;
    using System.Collections;
    using System.Collections.Concurrent;
    using System.Collections.Generic;
    using System.Diagnostics;
    using System.Linq;
    using System.Threading.Tasks;
    
    namespace ConsoleApp2
    {
        class Program
        {
            static void Main(string[] args)
            {
                ConcurrentBag<Stu> conStu = new ConcurrentBag<Stu>();
                ConcurrentBag<Stu> conStu2 = new ConcurrentBag<Stu>();
                
                int num = 1500000;//150万
    
                //获取集合
                var lst = GetStu(num);
    
    
                #region 串行循环
                    var watch = new Stopwatch();
                    watch.Start();
                    foreach (var item in lst)
                    {
                        conStu.Add(item);
                    }
    
                    watch.Stop();
                    var completeRequest = watch.ElapsedMilliseconds;
                    Console.WriteLine($"
    
    Foreach {num.ToString("N0")} 使用时间(毫秒):{completeRequest}");
                    Console.WriteLine($"conStu 集合中共:{conStu.Count + 1}条");
                #endregion
    
                #region 并行循环
                    var watch2 = new Stopwatch();
                    watch2.Start();
                    ParallelLoopResult result = Parallel.ForEach(lst, new ParallelOptions { MaxDegreeOfParallelism = Environment.ProcessorCount }, item =>
                    {
                        conStu2.Add(item);
                    });
    
                    watch2.Stop();
                    var completeRequest2 = watch2.ElapsedMilliseconds;
                    Console.WriteLine($"
    
     Parallel.ForEach  {num.ToString("N0")} 使用时间(毫秒):{completeRequest2}");
                    Console.WriteLine($"conStu2 集合中共:{conStu2.Count + 1}条");
                #endregion
    
            }
    
            public  static List<Stu> GetStu(int num)
            {
                List<Stu> lstStu = new List<Stu>();
                for (int i = 1; i < num; i++)
                {
                    Stu sModle = new Stu();
                    sModle.Id = i;
                    sModle.uName = "测试" + i;
                    lstStu.Add(sModle);
                }
                return lstStu;
            }
           
        }
    
    
    
        public class Stu
        {
            public int Id { get; set; }
    
            public String uName { get; set; }
        }
    }

      测试了3次,但结果还是用串行时间会少些

  • 相关阅读:
    依赖注入和控制反转概念及目的(新手必读)
    电商秒杀系统可能遇到的坑及思路
    Java中的ReentrantLock和synchronized两种锁定机制的对比
    Java集合---HashMap源码剖析
    Java中的字符串常量池
    redhat7:用户、组和权限
    redhat7下对用户账户的管理
    通过Tacker将NFV引入OpenStack
    github中的一个快捷键
    关于
  • 原文地址:https://www.cnblogs.com/personblog/p/13246599.html
Copyright © 2011-2022 走看看