ParallelCreateTxt

createTxt.cs

using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

namespace Explore
{
   public class CreateTxt
    {
       public static void CommomCreateTxt()
        {
            var ls = GetPersonLs();
            Stopwatch watch = new Stopwatch();
            watch.Start();
            foreach (var item in ls)
            {
                File.WriteAllText(string.Format(@"F:\project\teststatic\{0}.txt", item.Id), item.ToString(), Encoding.UTF8);
            }
            watch.Stop();
            Console.WriteLine("普通循环生成时间：{0}", watch.ElapsedMilliseconds.ToString());
            //423 440 
        }

       public static void ThreadPoolCreateTxt()
       {
           var ls = GetPersonLs();
           Stopwatch watch = new Stopwatch();
           watch.Start();

           ManualResetEvent eventX = new ManualResetEvent(false);
           //可以获取和设置线程池的最大线程数，即线程池中共有多少个线程。线程池中的线程数目仅受可用内存的限制。但是，线程池将对允许在进程中同时处于活动状态的线程数目强制实施限制（这取决于CPU的数目和其他因素）。默认情况下，每个系统处理器最多可以运行25个线程池线程。
           ThreadPool.SetMaxThreads(3, 3);
          // thr t = new thr(15, eventX);

           foreach (var item in ls)
           {
               ThreadPool.QueueUserWorkItem(x => {
                   File.WriteAllText(string.Format(@"F:\project\teststatic\{0}.txt", item.Id), item.ToString(), Encoding.UTF8);
               });
               
           }
           watch.Stop();
           Console.WriteLine("线程池生成时间：{0}", watch.ElapsedMilliseconds.ToString());
       }

       public static void ParallelCreateTxt()
        {
            var ls = GetPersonLs();
            Stopwatch watch = new Stopwatch();
            watch.Start();
            Parallel.ForEach(ls, new ParallelOptions{MaxDegreeOfParallelism=Environment.ProcessorCount}, item => { File.WriteAllText(string.Format(@"F:\project\teststatic\{0}.txt", item.Id), item.ToString(), Encoding.UTF8); });

            watch.Stop();
            Console.WriteLine("Parallel循环生成时间：{0}", watch.ElapsedMilliseconds.ToString());
            
        }

        static List<Person> GetPersonLs()
        {
            var ls = new List<Person>();

            for (int i = 0; i < 20000; i++)
            {
                ls.Add(new Person { Id = i, Name = string.Format("a{0}_{1}", i, i + i), Age = (i + 20) * i });
            }
            return ls;
        }


        /*
         * for (int i = 0; i < 10; i++)
             {
                 CommomCreateTxt();
                 //ParallelCreateTxt();

                 System.Threading.Thread.Sleep(1000);
             }
         */

        /*
         * 普通循环生成时间：455
 普通循环生成时间：257
 普通循环生成时间：241
 普通循环生成时间：258
 普通循环生成时间：249
 普通循环生成时间：250
 普通循环生成时间：284
 普通循环生成时间：270
 普通循环生成时间：251
 普通循环生成时间：262
         */




        /*
         * 
         * Parallel循环生成时间：300
 Parallel循环生成时间：178
 Parallel循环生成时间：170
 Parallel循环生成时间：284
 Parallel循环生成时间：425
 Parallel循环生成时间：171
 Parallel循环生成时间：159
 Parallel循环生成时间：161
 Parallel循环生成时间：158
 Parallel循环生成时间：159
         */
    }

   public class Person
   {
       public int Id { get; set; }
       public string Name { get; set; }

       public int Age { get; set; }

       public override string ToString()
       {
           return string.Format("Id={0} ,Name={1} Age={2}", this.Id, this.Name, this.Age);
       }
   }
}