多线程ManualResetEvent等待所有线程
Posted tags: 篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了多线程ManualResetEvent等待所有线程相关的知识，希望对你有一定的参考价值。 需求：成员A可能有几十个，我需要更新所有的A，然后根据A的数据，去更新成员B。 解决方案:思路是想通过多线程更新所有的A，然后通过等待线程来确定所有的A是否都更新完，最后更新B。 处理数据的方法 新建立的model 此处出现了新问题: 当线程大于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对象的大量产生和使用的简单性。 本质就是只通过1个ManualResetEvent 对象就可以实现同步N（N可以大于64）个线程 修改后的方法：(黄色荧光笔的都是改动的代码) 处理数据的方法需要小改一下： 此时，大于64条线程的可以使用了。 以上是关于多线程ManualResetEvent等待所有线程的主要内容，如果未能解决你的问题，请参考以下文章 为啥即使调用 Close()，等待 ManualResetEvent 的线程也会继续等待？ netframework中等待多个子线程执行完毕并计算执行时间 AutoResetEvent和ManualResetEvent（多线程操作）
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）
}
public class te
{
public Member member{ get; set; }
public ManualResetEvent MRevent { get; set; }//小于64线程的时候使用
public MutipleThreadResetEvent MTRevent { get; set; }//大于64线程的时候使用
}
/********************************************************************************
* 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();
}
}
}
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();//此处调用封装的方法
}