用互斥体解决多线程资源冲突问题

社区服务
高级搜索
猴岛论坛辅助工具用互斥体解决多线程资源冲突问题
发帖 回复
正序阅读 最近浏览的帖子最近浏览的版块
« 返回列表
0个回复

用互斥体解决多线程资源冲突问题

 楼层直达
mimi_rice

ZxID：55494225

等级: 上士
举报 只看楼主 使用道具 楼主   发表于: 2015-03-05 0

解决多线程资源冲突问题
本文由按键学院提供技术支持


按键学院交流群（1群已满）：376122403
零基础学按键精灵群（2群）：372671254




引用

故事就从一位童鞋的悲惨经历说起吧。
那是一个雷雨交加的夜晚
这位童鞋熬夜写了一个关于《赤月传说》交易功能的多线程多开脚本。
狂喜之余立马投身测试
测试的结果却让他的脸变成了屎色
他开了15个窗口，挂了半小时，就有10个窗口崩溃了。

他首先想到的是，会不会是电脑不给力，线程开多了导致的崩溃？
于是，他只开了5个窗口

啊~5个窗口崩了3个
这个问题困扰了他一个月，
后来才发现！
原来，游戏里规定，交易只能是一对一的
他没有在脚本中做处理
于是，启动脚本之后，所有的号都争着和交易号进行交易，
只有一个窗口抢到了和交易号交易的机会，其它的窗口没有抢到，就不断循环判断导致窗口崩溃
就像10个人争抢一个茅坑一样，1个人抢到了，其余9个人都掉坑里了……


怎么才能让他们好好排队上厕所呢？
很多童鞋可能会立马想到互斥体。
将交易的那段代码用互斥体保护起来，当一个线程在执行交易代码时，其它的线程就无法进行交易操作。
为了方便大家学习和使用，我们的06老湿提供了一段Api创建互斥体的代码范例~






API函数


引用
{:4_95:}
要用到三个Api函数：
CreateMutex
WaitForSingleObject
ReleaseMutex






函数名称  CreateMutex
函数功能创建互斥体
参数参数1：指定一个SECURITY_ATTRIBUTES结构，或传递零值，表示使用不允许继承的默认描述符
参数2：如创建进程希望立即拥有互斥体，则设为TRUE。一个互斥体同时只能由一个线程拥有。
参数3：指定互斥体对象的名字。
返回值如执行成功，就返回互斥体对象的句柄；零表示出错。







函数名称  WaitForSingleObject
函数功能[size=13px]检测对象的信号状态,当函数的执行时间超过参数2设置的间隔时间，就返回无信号状态,
参数参数1：对象句柄
参数2：定时时间间隔
返回值WAIT_OBJECT_0 0x00000000 ：核心对象已被激活
WAIT_TIMEOUT 0x00000102：等待超时
WAIT_FAILED 0xFFFFFFFF ：出现错误，可通过GetLastError得到错误代码








函数名称  ReleaseMutex
函数功能释放由线程拥有的一个互斥体的控制权
参数参数：指定一个互斥体的句柄。
返回值非零表示成功，零表示失败。



步骤





1、调用Api函数：CreateMutex函数创建一个新的互斥体，并且将创建之后返回的互斥体句柄赋值给环境变量：交易


2、交易代码执行之前，调用Api函数：WaitForSingleObject函数， 设置互斥体使用时长为30秒。（如果一个交易操作需要3分钟，则这里的使用时长设置为大于等于3分钟。）

   当第一条线程执行到 WaitForSingleObject函数时，会获取30秒的互斥体使用时长，在这30秒时间内，只有第一条          线程可以执行被互斥体保护起来的代码段，其它的线程都在等待。


3、交易代码执行之后，调用Api函数：ReleaseMutex函数， 释放互斥体使用权
   当30秒时间过后，第一条线程会释放对互斥体的控制权，让给下一条线程使用。






代码
复制代码
  1. Declare Function CreateMutex Lib "kernel32" Alias "CreateMutexA" (lpMutexAttributes As Long , ByVal bInitialOwner As Long, ByVal lpName As String) As Long
  2. Declare Function ReleaseMutex Lib "kernel32" Alias "ReleaseMutex" (ByVal hMutex As Long)
  3. Declare Function WaitForSingleObject Lib "kernel32" Alias "WaitForSingleObject" (ByVal hHandle As Long, ByVal dwMilliseconds As Long) As Long
  4. 'Declare Function CloseHandle lib "kernel32" (hdr as long) as Long
  6. Dimenv 交易
  7. 交易 = 创建互斥体()
  9. For 10
  10.     BeginThread  游戏交易
  11. Next
  13. Sub 游戏交易()
  14.     //绑定窗口
  15.     //登录帐号
  16.     //寻找npc
  17.     Call 锁定(交易, 30000)
  18.     //交易
  19.     Call 解锁(交易)
  20. End Sub
  22. Function 创建互斥体()
  23.     '/*随机生成互斥体名称
  24.     Dim TempStr, i
  25.     TempStr = "anjian_mutex_"
  26.     For i = 0 To 12
  27.         Randomize
  28.         TempStr = TempStr & Chr((24 * Rnd) + 65)
  29.     Next
  30.     '*/    
  31.     创建互斥体 = CreateMutex(0, true, TempStr)
  32. End Function
  34. Sub 关闭互斥体(hdr)
  35.     Call CloseHandle(hdr)
  36. End Sub
  38. Function 锁定(Hdr, Max)
  39.     锁定 = WaitForSingleObject(Hdr, Max)
  40. End Function
  42. Function 解锁(Hdr)
  43.     Call ReleaseMutex(Hdr)
  44. End Function
  46. /*
  47. Sub OnScriptExit()
  48.    TracePrint "关闭互斥体"
  49.    Call 关闭互斥体(交易)
  50. End Sub
  51. '*/  
注意1：
本例子中，在创建互斥体时，使用了随机产生互斥体的名称
随机名称是以 “anjian_mutex_”开头并且加上12个随机字母
随机名称这样复杂是为了避免名称冲突，如果有一样的名称存在，那么当前的互斥体就会创建失败



注意2：
代码中还有一个CloseHandle函数，被注释掉了
因为，我们的主线程结束得比其它的十条线程快，所以当十条线程还在创建启动的过程中，主线程就已经结束，并且触发了脚本停止事件，执行了关闭互斥体的命令
这样会导致，刚创建的互斥体被关闭的情况
所以，如果主线程结束得比其他线程快，就不要使用关闭互斥体命令了
互斥体所占用的内存空间并不大，不关闭也不影响





引用
那么，如果游戏规定， 登录帐号和交易 这两个操作都只能一个一个进行操作呢？
那么我们就需要设置两个互斥体：登录互斥体 和 交易互斥体  

代码：
复制代码
  1. Declare Function CreateMutex Lib "kernel32" Alias "CreateMutexA" (lpMutexAttributes As Long , ByVal bInitialOwner As Long, ByVal lpName As String) As Long
  2. Declare Function ReleaseMutex Lib "kernel32" Alias "ReleaseMutex" (ByVal hMutex As Long)
  3. Declare Function WaitForSingleObject Lib "kernel32" Alias "WaitForSingleObject" (ByVal hHandle As Long, ByVal dwMilliseconds As Long) As Long
  4. 'Declare Function CloseHandle lib "kernel32" (hdr as long) as Long
  6. Dimenv 交易,登录
  7. 登录 = 创建互斥体()
  8. 交易 = 创建互斥体()
  10. For 10
  11.     BeginThread  游戏交易
  12. Next
  14. Sub 游戏交易()
  16.     //绑定窗口
  17.       
  18.     Call 锁定(登录, 30000)
  19.     //登录帐号
  20.     Call 解锁(登录)
  21.     
  22.     //寻找npc
  23.     
  24.     Call 锁定(交易, 30000)
  25.     //交易
  26.     Call 解锁(交易)
  27. End Sub
  29. Function 创建互斥体()
  30.     '/*随机生成互斥体名称
  31.     Dim TempStr, i
  32.     TempStr = "anjian_mutex_"
  33.     For i = 0 To 12
  34.         Randomize
  35.         TempStr = TempStr & Chr((24 * Rnd) + 65)
  36.     Next
  37.     '*/    
  38.     创建互斥体 = CreateMutex(0, true, TempStr)
  39. End Function
  41. Sub 关闭互斥体(hdr)
  42.     Call CloseHandle(hdr)
  43. End Sub
  45. Function 锁定(Hdr, Max)
  46.     锁定 = WaitForSingleObject(Hdr, Max)
  47. End Function
  49. Function 解锁(Hdr)
  50.     Call ReleaseMutex(Hdr)
  51. End Function
  53. /*
  54. Sub OnScriptExit()
  55.    TracePrint "关闭互斥体"
  56. <span style="font-size: 14.2857151031494px;">Call 关闭互斥体(登录)</span>
  57.    Call 关闭互斥体(交易)
  58. End Sub
  59. '*/







{:5_141:}本文由按键学院提供技术支持{:5_141:}
零基础学按键精灵2015年开始招生！

全面系统回合制脚本教学
打赏 收藏 新鲜事

相关主题

回复 引用
　 鲜花[0]　 鸡蛋[0]
« 返回列表
发帖 回复