首页 > 代码库 > 多线程ManualResetEvent、等待所有线程
多线程ManualResetEvent、等待所有线程
需求:成员A可能有几十个,我需要更新所有的A,然后根据A的数据,去更新成员B。
解决方案:思路是想通过多线程更新所有的A,然后通过等待线程来确定所有的A是否都更新完,最后更新B。
Member B = ....;//B成员的model IList<Member> list = ......;//查出所有的A成员,装进list里。 ManualResetEvent[] manualEvents = new ManualResetEvent[list.Count]; //更新所有的A成员 for (int i = 0; i < list.Count; i++) { manualEvents[i] = new ManualResetEvent(false);//初始化的ManualResetEvent必须是false model = new te();//目前我只知道此处只能传一个参数,所以为了传递多个参数,我写了个model,然后把要参数都放进model里 model.MRevent = manualEvents[i]; model.member = list[i];//此处是我处理数据需要的参数,把成员的model传进去 ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model); } //等待所有线程执行完毕 WaitHandle.WaitAll(manualEvents); //更新B成员 model = new te(); model.member = B; model.MRevent = new ManualResetEvent(false); UpdateMember(model);
处理数据的方法
public void UpdateMember(object tsmodel) { te stateInfo = (te)tsmodel; Member member = stateInfo.member;//中间为处理数据更新成员数据 ...... stateInfo.MRevent.Set(); //将事件状态设置为终止状态,允许一个或多个等待线程继续(我个人理解是调用此方法,及为该线程结束,ManualResetEvent应该变成true) }
新建立的model
public class te { public Member member{ get; set; } public ManualResetEvent MRevent { get; set; }//小于64线程的时候使用 public MutipleThreadResetEvent MTRevent { get; set; }//大于64线程的时候使用 }
此处出现了新问题:
当线程大于64条时,会报错。应该是WaitHandle.WaitAll(manualEvents);这等待的线程数不能大于64。
错误信息:waithandles 的数目必须少于或等于 64 个。
经过网上查询,找到的解决办法,原文地址http://www.cnblogs.com/xiaofengfeng/archive/2012/12/27/2836183.html
原理:封装一个ManualResetEvent对象,一个计数器current,提供SetOne和WaitAll方法;
主线程调用WaitAll方法使ManualResetEvent对象等待唤醒信号;
各个子线程调用setOne方法 ,setOne每执行一次current减1,直到current等于0时表示所有子线程执行完毕 ,调用ManualResetEvent的set方法,这时主线程可以执行WaitAll之后的步骤。
目标:减少ManualResetEvent对象的大量产生和使用的简单性。
/******************************************************************************** * Copyright ? 2001 - 2010Comit. All Rights Reserved. * 文件:MutipleThreadResetEvent.cs * 作者:杨柳 * 日期:2010年11月13日 * 描述:封装 ManualResetEvent ,该类允许一次等待N(N>64)个事件执行完毕 * * 解决问题:WaitHandle.WaitAll(evetlist)方法最大只能等待64个ManualResetEvent事件 * *********************************************************************************/ using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Threading; namespace TestMutipleThreadRestEvent { /// <summary> /// 封装ManualResetEvent /// </summary> public class MutipleThreadResetEvent : IDisposable { private readonly ManualResetEvent done; private readonly int total; private long current; /// <summary> /// 构造函数 /// </summary> /// <param name="total">需要等待执行的线程总数</param> public MutipleThreadResetEvent(int total) { this.total = total; current = total; done = new ManualResetEvent(false); } /// <summary> /// 唤醒一个等待的线程 /// </summary> public void SetOne() { // Interlocked 原子操作类 ,此处将计数器减1 if (Interlocked.Decrement(ref current) == 0) { //当所以等待线程执行完毕时,唤醒等待的线程 done.Set(); } } /// <summary> /// 等待所以线程执行完毕 /// </summary> public void WaitAll() { done.WaitOne(); } /// <summary> /// 释放对象占用的空间 /// </summary> public void Dispose() { ((IDisposable)done).Dispose(); } } }
本质就是只通过1个ManualResetEvent 对象就可以实现同步N(N可以大于64)个线程
修改后的方法:
Member B = ......;//B成员的model IList<Member> list = ......;//查出所有的A成员,装进list里。 //更所有A成员 using (var countdown = new MutipleThreadResetEvent(list.Count)) { for (int i = 0; i < list.Count; i++) { model = new te(); model.MTRevent = countdown; model.member = list[i]; //开启N个线程,传递MutipleThreadResetEvent对象给子线程 ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model); } //等待所有线程执行完毕 countdown.WaitAll(); } //更新B成员 using (var countdown = new MutipleThreadResetEvent(1)) { model = new te(); model.MTRevent = countdown; model.member = B; //开启N个线程,传递MutipleThreadResetEvent对象给子线程 ThreadPool.QueueUserWorkItem(new WaitCallback(UpdateMember), model); //等待所有线程执行完毕 countdown.WaitAll(); }
处理数据的方法需要小改一下:
public void UpdateMember(object tsmodel) { te stateInfo = (te)tsmodel; Member member = stateInfo.member; //中间为处理数据更新成员数据 ...... stateInfo.MTRevent.SetOne();//此处调用封装的方法 }
此时,大于64条线程的可以使用了。
多线程ManualResetEvent、等待所有线程
声明:以上内容来自用户投稿及互联网公开渠道收集整理发布,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任,若内容有误或涉及侵权可进行投诉: 投诉/举报 工作人员会在5个工作日内联系你,一经查实,本站将立刻删除涉嫌侵权内容。