真·多线程防崩溃防卡死【线程自动分配保证处于工作状态，能超时重试】

xiekyle

学习下，看看好不好使，谢谢分享

anyuezhiji

专注TX营xiao 发表于 2016-9-4 16:52
不行，请更新下带换IP功能谢谢，换了IP好像之前的线程有点没有处理完自动跳过

  

数据类型名	公开	备 注
线程传参
成员名	类 型	传址	数组	备 注
数据序号
状态信号				表示线程ID的状态，0为空闲，1为繁忙，2为刚处理完成
线程序号
启动时间
重试次数

.版本 2<br /> <br /> .数据类型 线程传参<br />     .成员 数据序号<br />     .成员 状态信号, , , , 表示线程ID的状态，0为空闲，1为繁忙，2为刚处理完成<br />     .成员 线程序号<br />     .成员 启动时间<br />     .成员 重试次数

  

子程序名	返回值类型	公开	备 注
_跳转线程
参数名	类 型	参考	可空	数组	备 注
线程ID

变量名	类 型	静态	数组	备 注
数据ID
状态	文本型

' 通讯信号_数组 [线程ID].状态信号：表示线程ID的状态，0为空闲，1为繁忙，2为刚处理完成，3为超时被结束
判断循环首 (正计次 ＜ 数据总量 且 通讯信号_数组 [线程ID].状态信号 ＝ 0 且 结束信号 ＝ 假)
通讯信号_数组 [线程ID].状态信号 ＝ 1
' ——————————————————————
进入许可区 (许可证)
正计次 ＝ 正计次 ＋ 1  ' InterlockedIncrement (正计次)
如果真 (正计次 ＞ 数据总量)
退出许可区 (许可证)
跳出循环 ()
数据ID ＝ 正计次
退出许可区 (许可证)
' ——————————————————————
' ——————————————————————
通讯信号_数组 [线程ID].数据序号 ＝ 数据ID
通讯信号_数组 [线程ID].线程序号 ＝ 线程ID
通讯信号_数组 [线程ID].重试次数 ＝ 超时重试
判断循环首 (通讯信号_数组 [线程ID].重试次数 ＞ -1 且 通讯信号_数组 [线程ID].状态信号 ＝ 1 且 结束信号 ＝ 假)
通讯信号_数组 [线程ID].启动时间 ＝ 取启动时间 ()
核心线程句柄_数组 [线程ID] ＝ 线程_启动 (&核心程序, 取指针地址 (通讯信号_数组 [线程ID]), )
判断循环首 (结束信号 ＝ 假 且 数据ID ＞ 0)  ' 无限循环，判断
程序_延时 (5)
如果真 (通讯信号_数组 [线程ID].状态信号 ＝ 2)
跳出循环 ()
如果真 (是否挂起 ＝ 假 且 取启动时间 () － 通讯信号_数组 [线程ID].启动时间 ＞ 超时时长 且 通讯信号_数组 [线程ID].状态信号 ＝ 1)
' 强制结束线程 (线程句柄_数组 [线程ID])
线程_销毁 (核心线程句柄_数组 [线程ID])
超时处理 (数据ID, 线程ID)
InterlockedIncrement (超时计数)
' 通讯信号_数组 [线程ID].状态信号 ＝ 3
跳出循环 ()

判断循环尾 ()
如果真 (通讯信号_数组 [线程ID].重试次数 ＝ 0 且 通讯信号_数组 [线程ID].状态信号 ＝ 1)
InterlockedIncrement (失败计数)
跳出循环 ()
通讯信号_数组 [线程ID].重试次数 ＝ 通讯信号_数组 [线程ID].重试次数 － 1
判断循环尾 ()
' ——————————————————————
' ——————————————————————
进入许可区 (许可证)
如果真 (数据ID ＝ 数据总量)
正计次 ＝ 正计次 ＋ 1
逆计次 ＝ 逆计次 － 1
退出许可区 (许可证)
通讯信号_数组 [线程ID].状态信号 ＝ 0
判断循环尾 ()

i支持库列表	支持库注释
EThread	多线程支持库
shellEx	扩展功能支持库一

.版本 2<br /> .支持库 EThread<br /> .支持库 shellEx<br /> <br /> .子程序 _跳转线程<br /> .参数 线程ID<br /> .局部变量 数据ID<br /> .局部变量 状态, 文本型<br /> <br /> ' 通讯信号_数组 [线程ID].状态信号：表示线程ID的状态，0为空闲，1为繁忙，2为刚处理完成，3为超时被结束<br /> .判断循环首 (正计次 ＜ 数据总量 且 通讯信号_数组 [线程ID].状态信号 ＝ 0 且 结束信号 ＝ 假)<br />     通讯信号_数组 [线程ID].状态信号 ＝ 1<br />     ' ——————————————————————<br />     进入许可区 (许可证)<br />     正计次 ＝ 正计次 ＋ 1  ' InterlockedIncrement (正计次)<br />     .如果真 (正计次 ＞ 数据总量)<br />         退出许可区 (许可证)<br />         跳出循环 ()<br />     .如果真结束<br />     数据ID ＝ 正计次<br />     退出许可区 (许可证)<br />     ' ——————————————————————<br />     ' ——————————————————————<br />     通讯信号_数组 [线程ID].数据序号 ＝ 数据ID<br />     通讯信号_数组 [线程ID].线程序号 ＝ 线程ID<br />     通讯信号_数组 [线程ID].重试次数 ＝ 超时重试<br />     .判断循环首 (通讯信号_数组 [线程ID].重试次数 ＞ -1 且 通讯信号_数组 [线程ID].状态信号 ＝ 1 且 结束信号 ＝ 假)<br />         通讯信号_数组 [线程ID].启动时间 ＝ 取启动时间 ()<br />         核心线程句柄_数组 [线程ID] ＝ 线程_启动 (&核心程序, 取指针地址 (通讯信号_数组 [线程ID]), )<br />         .判断循环首 (结束信号 ＝ 假 且 数据ID ＞ 0)  ' 无限循环，判断<br />             程序_延时 (5)<br />             .如果真 (通讯信号_数组 [线程ID].状态信号 ＝ 2)<br />                 跳出循环 ()<br />             .如果真结束<br />             .如果真 (是否挂起 ＝ 假 且 取启动时间 () － 通讯信号_数组 [线程ID].启动时间 ＞ 超时时长 且 通讯信号_数组 [线程ID].状态信号 ＝ 1)<br />                 ' 强制结束线程 (线程句柄_数组 [线程ID])<br />                 线程_销毁 (核心线程句柄_数组 [线程ID])<br />                 超时处理 (数据ID, 线程ID)<br />                 InterlockedIncrement (超时计数)<br />                 ' 通讯信号_数组 [线程ID].状态信号 ＝ 3<br />                 跳出循环 ()<br />             .如果真结束<br /> <br />         .判断循环尾 ()<br />         .如果真 (通讯信号_数组 [线程ID].重试次数 ＝ 0 且 通讯信号_数组 [线程ID].状态信号 ＝ 1)<br />             InterlockedIncrement (失败计数)<br />             跳出循环 ()<br />         .如果真结束<br />         通讯信号_数组 [线程ID].重试次数 ＝ 通讯信号_数组 [线程ID].重试次数 － 1<br />     .判断循环尾 ()<br />     ' ——————————————————————<br />     ' ——————————————————————<br />     进入许可区 (许可证)<br />     .如果真 (数据ID ＝ 数据总量)<br />         正计次 ＝ 正计次 ＋ 1<br />     .如果真结束<br />     逆计次 ＝ 逆计次 － 1<br />     退出许可区 (许可证)<br />     通讯信号_数组 [线程ID].状态信号 ＝ 0<br /> .判断循环尾 ()

  

子程序名	返回值类型	公开	备 注
挂起核心线程
参数名	类 型	参考	可空	数组	备 注
是否切换IP	逻辑型

变量名	类 型	静态	数组	备 注
线程ID	整数型

如果 (是否挂起 ＝ 假)
是否挂起 ＝ 真
挂起计时 ＝ 取启动时间 ()
计次循环首 (线程总数, 线程ID)
如果真 (是否切换IP)
通讯信号_数组 [线程ID].重试次数 ＝ 超时重试 ＋ 1
线程_挂起 (核心线程句柄_数组 [线程ID])
计次循环尾 ()
信息框 (“已经挂起，请先恢复...”, 0, , )
' 在换IP时，是否切换IP参数为真，把线程重试次数增加

.版本 2<br /> <br /> .子程序 挂起核心线程<br /> .参数 是否切换IP, 逻辑型, 可空<br /> .局部变量 线程ID, 整数型<br /> <br /> .如果 (是否挂起 ＝ 假)<br />     是否挂起 ＝ 真<br />     挂起计时 ＝ 取启动时间 ()<br />     .计次循环首 (线程总数, 线程ID)<br />         .如果真 (是否切换IP)<br />             通讯信号_数组 [线程ID].重试次数 ＝ 超时重试 ＋ 1<br />         .如果真结束<br />         线程_挂起 (核心线程句柄_数组 [线程ID])<br />     .计次循环尾 ()<br /> .否则<br />     信息框 (“已经挂起，请先恢复...”, 0, , )<br /> <br /> '在换IP时，是否切换IP参数为真，把线程重试次数增加

专注腾讯营销

anyuezhiji 发表于 2016-9-4 13:28

不行，请更新下带换IP功能谢谢，换了IP好像之前的线程有点没有处理完自动跳过

anyuezhiji

专注腾讯营销 发表于 2016-9-4 13:11
不知道这个多线程是否可以加拨号换IP，没有找到地方，楼主看看是否可以加拨号

专注腾讯营销

不知道这个多线程是否可以加拨号换IP，没有找到地方，楼主看看是否可以加拨号

小小莹莹

支持楼主，来看看的

xujunhui

QQ1515976582 上排卖。。。。。。。。。。。

星云散落

学习一下了

anyuezhiji

真·多线程防崩溃防卡死.rar (176.21 KB, 下载次数: 1010)

2016-9-3 23:57 上传

点击文件名下载附件
主楼是用7zip打包的，有人反应用低版本的winrar解压不行，
这里补个winrar5.21打包的

key356

文件貌似损坏？？