C#使用AutoResetEvent实现同步
前几天碰到一个线程的顺序执行的问题,就是一个异步线程往a接口发送一个数据请求。另外一个异步线程往b接口发送一个数据请求,当a和b都执行成功了,再往c接口发送一个请求。说真的,一直做bs项目,对线程了解,还真不多。就知道autoresetevent这个东西和线程有关,用于处理线程切换之类,于是决定用autoresetevent来处理上面的问题。
于是网上查找相关资料:
原来,autoresetevent在.net多线程编程中经常用到。当某个线程调用waitone方法后,信号处于发送状态,该线程会得到信号, 程序就会继续向下执行,否则就等待。而且 autoresetevent.waitone()每次只允许一个线程进入,当某个线程得到信号后,autoresetevent会自动又将信号置为不发送状态,其他调用waitone的线程只有继续等待.也就是说,autoresetevent一次只唤醒一个线程,其他线程还是堵塞。
简介
autoresetevent(bool initialstate):构造函数,用一个指示是否将初始状态设置为终止的布尔值初始化该类的新实例。
false:无信号,子线程的waitone方法不会被自动调用
true:有信号,子线程的waitone方法会被自动调用
reset ():将事件状态设置为非终止状态,导致线程阻止;如果该操作成功,则返回true;否则,返回false。
set ():将事件状态设置为终止状态,允许一个或多个等待线程继续;如果该操作成功,则返回true;否则,返回false。
waitone(): 阻止当前线程,直到收到信号。
waitone(timespan, boolean) :阻止当前线程,直到当前实例收到信号,使用 timespan 度量时间间隔并指定是否在等待之前退出同步域。
waitall():等待全部信号。
实现
class program { static void main() { request req = new request(); //这个人去干三件大事 thread getcarthread = new thread(new threadstart(req.interfacea)); getcarthread.start(); thread gethousethead = new thread(new threadstart(req.interfaceb)); gethousethead.start(); //等待三件事都干成的喜讯通知信息 autoresetevent.waitall(req.autoevents); //这个人就开心了。 req.interfacec(); system.console.readkey(); } } public class request { //建立事件数组 public autoresetevent[] autoevents = null; public request() { autoevents = new autoresetevent[] { new autoresetevent(false), new autoresetevent(false) }; } public void interfacea() { system.console.writeline("请求a接口"); thread.sleep(1000*2); autoevents[0].set(); system.console.writeline("a接口完成"); } public void interfaceb() { system.console.writeline("请求b接口"); thread.sleep(1000 * 1); autoevents[1].set(); system.console.writeline("b接口完成"); } public void interfacec() { system.console.writeline("两个接口都已经请求完,正在处理c"); } }
注意,waitone 或是waitall 最好都加上超时时间。否则没有收到信号,线程一直会阻塞。
后话
这个只是上面的场景的一个简化,主要是用来解决刚刚我说的那个场景的问题。
以上是自己对autoresetevent的使用总结。不足之处请各位指点一二。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。