多线程实践

多线程实践

  一直对多线程不感冒，常见的场景下用不到这种技术，所以一直不愿去了解，但是遇到一些耗时的任务时就要考虑了。下面的例子是项目中遇到的，不想说这个如何的高深，只想说我也不是很了解到底如何工作的，到底带来了多少的效率提升。书上的理论要多枯燥有多枯燥，枯燥的我都不想去动手写里面的例子，下面的例子是实际用到的，还有些意思，不管怎么说开个头吧。

　　1.ManualResetEvent[] doEvents = new ManualResetEvent[threadCount]; 
　　通知一个或多个正在等待的线程已发生事件。 谁通知谁，发生的事情是指？一头雾水

　　2.ThreadPool.QueueUserWorkItem(new WaitCallback(DealData), new object[] { i, doEvents[i] });
　　线程池中创建一个线程池线程来执行指定方法（用委托WaitCallBack表示），并将该线程排入线程池的队列等待执行。

　　3.doEvent.Set(); 
　　将事件状态设置为终止状态，允许一个或多个等待线程继续。

　　4.WaitHandle.WaitAll(doEvents);
　　 等待指定数组中的所有元素都收到信号。

来看下面的例子，
SendDealSucessEmailFromQueue()方法：threadCount是一个配置项，指定一次要开多少个线程，曾有人建议为了安全起见，机器是有好个核就开多少个线程这里假设是5，不知道有没有道理有待研究。dataNum也是一个配置项，指定一个线程要处理多少订单数据，这里假设是50。ManualResetEvent[] doEvents = new ManualResetEvent[threadCount]，指定每次启动5个线程。然后循环doEvents[i] = newManualResetEvent(false);使用false作为参数通知当前线程等待此线程完成之后再完成当前线程的工作。ThreadPool.QueueUserWorkItem(new WaitCallback(DealData), new object[] { i, doEvents[i] }); 在线程池中添加线程来执行DealData方法，给这个方法传递一个参数，这个参数是一个对象数组，数组的第一项是当前第几个线程，就是线程号，第二个是线程的事件（请原谅我这么翻译，貌似没有看到ManualResetEvent这个类的中文名字是什么，看样子像手动重置事件，我这里简称线程事件）。注意for循环外面的一句话WaitHandle.WaitAll(doEvents);，这里先不解释待说完循环中调用的DealData方法之后再说。

DealData(object eventParams)方法：上面说到给他传递的参数是一个对象数组，所以int threadId = (int)(((object[])eventParams)[0]); ManualResetEvent doEvent = (ManualResetEvent)(((object[])eventParams)[1]);这两句很好理解，就是从这个对象数组中把实参值转换过来。int tmpCount = orderList.Count / threadCount;计算每个线程要处理的订单数量，要说的是因为要判断存在有要处理的订单才会开线程来处理，所以使用静态变量orderList。下面的这个for循环需要耐心琢磨，其实在SendDealSucessEmailFromQueue()这个方法执行完之后就已经开了5个线程，这时每个线程在做些什么事情我们是不能控制的，只知道有5个线程像脱缰野马一样地跑，在执行DealData(object eventParams)的时候是不知道当前是的线程是这5匹马中的那一匹，所以在这个for循环中我们就需要给他们分配工作，具体来说就是第0个线程处理0-49个订单，第1个线程处理50-99个，第2个线程处理100-149个，第3个线程处理200-249个，注意我这里都是用数组下标来解释。分配完即执行，执行完之后调用doEvent.Set();将当前线程置为终止。

再回到SendDealSucessEmailFromQueue()方法的最后一句WaitHandle.WaitAll(doEvents);等待线程事件中的所有任务执行完成之后继续当前线程，就是继续往下跑了，就是主程序了，可以理解为回到Main()方法中了。

    /// <summary>
    /// 处理订单邮件
    /// </summary>
    public class OrderEmailProcess
    {
        /// <summary>
        /// 日志
        /// </summary>
        private static readonly ILog logger = LogManager.GetLogger(typeof(OrderEmailProcess));
        static List<Corp.CorpFlightADTKJob.Entity.FltOrderInfoEntity.OrderInfoEntity> orderList = new List<Entity.FltOrderInfoEntity.OrderInfoEntity>();
        static int threadCount = 0;
        static int dataNum = 0;

        /// <summary>
        /// 发送成交确认邮件
        /// 因为发邮件接口中占用了emailtype：8，所以使用4096，这里需要处理emailtype
        /// </summary>
        public static void SendDealSucessEmailFromQueue()
        {
            threadCount = int.Parse(ConfigurationManager.AppSettings["ThreadCount"]);
            dataNum = int.Parse(ConfigurationManager.AppSettings["DataNum"]);
            string logMsg = "";
            orderList = CorpProcessDB.GetDealConfirmEmailQueue(ConnStrFactory.CorpProcessDB_Select, threadCount * dataNum);
            if (orderList != null && orderList.Count > 0)
            {
                //记录日志
                for (int i = 0; i < orderList.Count; i++)
                {
                    logMsg += string.Format("OrderID:{0} Uid:{1} EmailType:{2}", orderList[i].OrderID, orderList[i].Uid, orderList[i].EmailType) + "
";
                }
                logger.Info("自动发邮件", logMsg);
                ManualResetEvent[] doEvents = new ManualResetEvent[threadCount];
                for (int i = 0; i < threadCount; i++)
                {
                    doEvents[i] = new ManualResetEvent(false);
                    ThreadPool.QueueUserWorkItem(new WaitCallback(DealData), new object[] { i, doEvents[i] });
                }
                WaitHandle.WaitAll(doEvents);
            }
        }

        /// <summary>
        /// 处理线程方法
        /// </summary>
        /// <param name="eventParams"></param>
        private static void DealData(object eventParams)
        {
            int threadId = (int)(((object[])eventParams)[0]);      //当前线程ID
            ManualResetEvent doEvent = (ManualResetEvent)(((object[])eventParams)[1]);
            int tmpCount = orderList.Count / threadCount;       //平均每个线程处理数据

            for (int i = 0; i < orderList.Count; i++)
            {
                if (i < (threadId) * tmpCount)
                    continue;

                if ((i >= (threadId + 1) * tmpCount) && threadId != (threadCount - 1))
                    break;

                doDetailEvent(orderList[i]);
            }
            doEvent.Set();
        }

        /// <summary>
        /// 发邮件
        /// </summary>
        /// <param name="item"></param>
        /// <param name="threadId"></param>
        private static void doDetailEvent(Corp.CorpFlightADTKJob.Entity.FltOrderInfoEntity.OrderInfoEntity order)
        {
            int emailsendtime = order.EmailType;
            if ((emailsendtime & 8) == 8)
            {
                emailsendtime = emailsendtime + 4088;
            }
            CorpEmaiWSlHelper.SendCorpConfirmMail(order.OrderID, order.Uid, "N", emailsendtime, ""); 
        }
    }

如果你觉得上面的例子跑不起来，那么下面的例子可以让你在自己的机器上跑起来。这是一个web页面，OrderInfoEntity这个类写在另外一个文件中，这里和在一起展示。

    public partial class About : System.Web.UI.Page
    {
        int threadCount = 5;
        int dataNum = 50;
        static string msg = "";
        protected void Page_Load(object sender, EventArgs e)
        {
            msg = "";
            SendDealSucessEmailFromQueue();
            Response.Write(msg);
        }

        public List<OrderInfoEntity> orderList;
        public void SendDealSucessEmailFromQueue()
        {
            threadCount = 5;
            dataNum = 50;
            orderList = GetDealConfirmEmailQueue(threadCount * dataNum);
            if (orderList != null && orderList.Count > 0)
            {
                ManualResetEvent[] doEvents = new ManualResetEvent[threadCount];
                for (int i = 0; i < threadCount; i++)
                {
                    doEvents[i] = new ManualResetEvent(false);
                    ThreadPool.QueueUserWorkItem(new WaitCallback(DealData), new object[] { i, doEvents[i] });
                }
                WaitHandle.WaitAll(doEvents);
            }
        }

        public void DealData(object eventParams)
        {
            int threadId = (int)(((object[])eventParams)[0]);      //当前线程ID
            ManualResetEvent doEvent = (ManualResetEvent)(((object[])eventParams)[1]);
            int tmpCount = orderList.Count / threadCount;       //平均每个线程处理数据

            for (int i = 0; i < orderList.Count; i++)
            {
                if (i < (threadId) * tmpCount)
                    continue;

                if ((i >= (threadId + 1) * tmpCount) && threadId != (threadCount - 1))
                    break;

                doDetailEvent(orderList[i]);
            }
            doEvent.Set();
        }
        
        static void doDetailEvent(OrderInfoEntity order)
        {
            msg += order.OrderID.ToString() + "</br>";
        }

        /// <summary>
        /// 添加订单列表
        /// </summary>
        /// <param name="p"></param>
        /// <returns></returns>
        private static List<OrderInfoEntity> GetDealConfirmEmailQueue(int p)
        {
            List<OrderInfoEntity> result = new List<OrderInfoEntity>();
            for (int i = 0; i < p; i++)
            {
                OrderInfoEntity entity = new OrderInfoEntity(i + 1);
                result.Add(entity);
            }
            return result;
        }
    }

    public class OrderInfoEntity
    {
        private int _orderID;
        public int OrderID
        { get { return _orderID; } set { _orderID = value; } }
        public OrderInfoEntity(int orderid)
        {
            this._orderID = orderid;
        }
    }

                #region 异步读取数据
                long logID1 = RequestManager.newSubRequest(), logID2 = RequestManager.newSubRequest(), logID3 = RequestManager.newSubRequest();
                Task<List<CorpFlightSearchFlightsEntity>> taskNormalFlts = Task.Factory.StartNew<List<CorpFlightSearchFlightsEntity>>(() => SearchNormalFlights(searchRequest, logID1));
                Task<List<CorpFlightSearchFlightsEntity>> taskCorpFlts = Task.Factory.StartNew<List<CorpFlightSearchFlightsEntity>>(() => SearchCorpFlightsOnly(searchRequest, logID2));
                Task<List<CorpFlightSearchFlightsEntity>> taskMultiSpecialFlts = null;
                if (searchRequest.FlightWay == "D")
                {
                    taskMultiSpecialFlts = Task.Factory.StartNew<List<CorpFlightSearchFlightsEntity>>(() => SearchMultiSpecialFlights(searchRequest, logID3));
                    Task.WaitAll(taskNormalFlts, taskCorpFlts, taskMultiSpecialFlts);
                }
                else
                {
                    Task.WaitAll(taskNormalFlts, taskCorpFlts);
                }

                normalFlts = taskNormalFlts.Result;
                corpFlts = taskCorpFlts.Result;
                multiSpecialFlts = taskMultiSpecialFlts != null ? taskMultiSpecialFlts.Result : null;
                #endregion

作者：Tyler Ning 
出处：http://www.cnblogs.com/tylerdonet/ 
本文版权归作者和博客园共有，欢迎转载，但未经作者同意必须保留此段声明，且在文章页面明显位置给出原文连接，如有问题，可以通过以下邮箱地址williamningdong@gmail.com  联系我，非常感谢。

 

分类: 经验来源于实践

标签: asp.net