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

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

子程序名	返回值类型	公开	备注
_跳转线程
参数名	类型	参考	可空	数组	备注
线程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参数为真，把线程重试次数增加