// ***********************************************************************// Assembly         : Share.Code.MultiThreadTest// Author           : Amy// Created          : 07-15-2014//// Last Modified By : Amy// Last Modified On : 07-18-2014// ***********************************************************************// <copyright file="Program.cs" company="Microsoft">//     Copyright (c) Microsoft. All rights reserved.// </copyright>// <summary></summary>// ***********************************************************************using System;using System.Collections.Generic;namespace Share.Code.MultiThreadTest{    /// <summary>    /// Program    /// </summary>    class Program    {        /// <summary>        /// 入口        /// </summary>        /// <param name="args">参数</param>        static void Main(string[] args)        {            List<long> list = new List<long>();                        for (int i = 0; i < 10000000; i++)            {                list.Add(i);            }            DateTime start = DateTime.Now;            DateTime end = DateTime.Now;            long sum = 0;            for (int i = 0; i < list.Count; i++)            {                sum += list[i];            }            end = DateTime.Now;            Console.WriteLine("主线程结果:" + sum + ",耗时:" + ((TimeSpan)(end - start)).TotalMilliseconds);            start = DateTime.Now;            SumMultiThread thread = new SumMultiThread(list, 2);            thread.Execute();            end = DateTime.Now;            Console.WriteLine("多线程结果是:" + thread.Result + ",耗时:" + ((TimeSpan)(end - start)).TotalMilliseconds);            Console.Read();        }    }}

// ***********************************************************************// Assembly         : Share.Code.MultiThreadTest// Author           : Amy// Created          : 07-18-2014//// Last Modified By : Amy// Last Modified On : 07-18-2014// ***********************************************************************// <copyright file="SumMultiThread.cs" company="Microsoft">//     Copyright (c) Microsoft. All rights reserved.// </copyright>// <summary></summary>// ***********************************************************************using System;using System.Collections.Generic;using System.Threading;namespace Share.Code.MultiThreadTest{    /// <summary>    /// 利用多线程求和    /// </summary>    public class SumMultiThread    {        /// <summary>        /// 通知一个线程或多个线程正在发生的事情        /// </summary>        private List<ManualResetEvent> manualEventList = new List<ManualResetEvent>();        /// <summary>        /// 要处理的数据        /// </summary>        private List<long> data = http://www.mamicode.com/new List<long>();        /// <summary>        /// 子线程结果        /// </summary>        private List<long> subThreadResult = new List<long>();        /// <summary>        /// 子线程数量        /// </summary>        private int subThreadCount;        /// <summary>        /// 构造方法        /// </summary>        /// <param name="data">要处理的数据</param>        /// <param name="subThreadCount">线程的个数</param>        public SumMultiThread(List<long> data, int subThreadCount)        {            this.data =http://www.mamicode.com/ data;            if (subThreadCount >= 1)            {                this.subThreadCount = subThreadCount;            }            else            {                this.subThreadCount = 1;            }        }        /// <summary>        /// 处理结果        /// </summary>        public long Result        {            get;            set;        }        /// <summary>        /// 执行方法        /// </summary>        public void Execute()        {            for (int i = 0; i < this.subThreadCount; i++)            {                ManualResetEvent mre = new ManualResetEvent(false);                this.manualEventList.Add(mre);                ThreadPool.QueueUserWorkItem(this.ThreadMethod, i);            }            WaitHandle.WaitAll(this.manualEventList.ToArray());            // 把每个线程的计算结果加起来            long sum = 0;            for (int i = 0; i < this.subThreadResult.Count; i++)            {                sum += this.subThreadResult[i];            }            this.Result = sum;        }        /// <summary>        /// 线程方法        /// </summary>        /// <param name="obj">对象</param>        private void ThreadMethod(object obj)        {            DateTime start = DateTime.Now;            DateTime end = DateTime.Now;            int index = (int)obj;            int dataPerThread = 0;            if (this.data != null && this.data.Count > 0)            {                dataPerThread = this.data.Count / this.subThreadCount;            }            long sum = 0;            if (index == (this.subThreadCount - 1))            {                // 最后一个线程要                sum = 0;                for (int i = index * dataPerThread; i < this.data.Count; i++)                {                    sum += this.data[i];                }            }            else            {                // 其他线程                for (int i = index * dataPerThread; i < (index * dataPerThread) + dataPerThread && i < this.data.Count; i++)                {                    sum += this.data[i];                }            }            this.subThreadResult.Add(sum);            end = DateTime.Now;            Console.WriteLine("线程" + index + "执行完毕,耗时" + ((TimeSpan)(end - start)).TotalMilliseconds);                        this.manualEventList[index].Set();        }    }}