# 易语言多线程任务投递系统（基于精易模块和鱼刺多线程模块） ```易语言 .版本 2 .支持库 EThread .支持库 spec .程序集 程序集1 .程序集变量 线程池, 鱼刺类_线程池Ex .程序集变量 临界区, 鱼刺类_临界许可 .程序集变量 任务队列, 鱼刺类_队列Ex .程序集变量 已处理任务, 鱼刺类_HASH表 .程序集变量 是否正在处理, 逻辑型 .程序集变量 线程池大小, 整数型 .子程序 _启动子程序, 整数型 .局部变量 i, 整数型 线程池大小 ＝ 10 ' 根据CPU核心数调整 线程池.创建 (线程池大小, , , , , , , , , , , ) 临界区.创建 () 任务队列.创建 () 已处理任务.创建 () ' 模拟主循环 .判断循环首 (真) 获取数据并投递任务 () 延时 (100) ' 控制获取频率 .判断循环尾 () 返回 (0) .子程序 获取数据并投递任务 .局部变量 数据列表, 文本型, , "0" .局部变量 i, 整数型 .局部变量 当前任务, 文本型 ' 模拟获取数据 数据列表 ＝ { "任务1", "任务2", "任务3", "任务4", "任务5", "任务6", "任务1" } ' 注意有重复任务 临界区.进入 () .计次循环首 (取数组成员数 (数据列表), i) 当前任务 ＝ 数据列表 [i] ' 检查是否已处理过 .如果 (已处理任务.是否存在 (当前任务) ＝ 假) 已处理任务.添加 (当前任务, "1") ' 标记为已处理 任务队列.压入文本 (当前任务) ' 加入队列 .否则 调试输出 ("跳过重复任务: ", 当前任务) .如果结束 .计次循环尾 () ' 如果线程池空闲且有任务，则投递 .如果真 (是否正在处理 ＝ 假 且 任务队列.取数量 () ＞ 0) 是否正在处理 ＝ 真 线程池.投递任务 (&处理任务, , , , , , , , , , , ) .如果真结束 临界区.退出 () .子程序 处理任务 .局部变量 当前任务, 文本型 .局部变量 队列数量, 整数型 .判断循环首 (真) 临界区.进入 () 队列数量 ＝ 任务队列.取数量 () .如果真 (队列数量 ＝ 0) 是否正在处理 ＝ 假 临界区.退出 () 跳出循环 () .如果真结束 任务队列.弹出文本 (当前任务) 临界区.退出 () ' 执行任务 执行具体任务 (当前任务) 延时 (10) ' 防止CPU占用过高 .判断循环尾 () .子程序 执行具体任务, , 整数型 .参数 任务内容, 文本型 ' 这里是实际任务处理代码 调试输出 ("正在处理任务: ", 任务内容) 延时 (取随机数 (500, 2000)) ' 模拟任务执行时间 调试输出 ("任务完成: ", 任务内容) ``` ## 代码说明 1. 使用鱼刺类_线程池Ex管理线程池，避免频繁创建销毁线程 2. 使用鱼刺类_队列Ex作为任务队列，保证线程安全 3. 使用鱼刺类_HASH表记录已处理任务，防止重复投递 4. 临界区保护共享资源访问 5. 动态任务投递机制，只在有任务且线程池空闲时投递 ## 三条额外需要注意的逻辑点 1. 线程池大小应根据实际CPU核心数调整，过大反而会降低性能 2. 任务队列和已处理HASH表需要定期清理，防止内存无限增长 3. 任务执行函数中应做好异常处理，避免单个任务失败影响整个线程池 [2025-04-11 10:42:24 | AI写代码神器 | 924点数解答]