AIWROK软件多线程thread1.runJsFile例子

QQ896757558 · 发表于 2025-4-15 09:25:55

T = time.nowStamp();

// 正确启动两个线程（线程名必须不同！）
var thread1 = new thread(); // 线程对象1
var thread2 = new thread(); // 线程对象2
thread1.runJsFile('线程1.js', 'worker1'); // 线程名用"worker1"
thread2.runJsFile('线程2.js', 'worker2'); // 线程名用"worker2"

// 监控循环（10秒后停止线程1）
while (true) {
printl("正常运行");
sleep.millisecond(1000);

if (time.nowStamp() - T > 10000) {
thread1.stop(); // 停止线程1（通过对象实例）
break; // 退出监控循环
}
}

这段代码的主要功能是启动两个独立的JavaScript线程，并监控它们的运行状态。10秒后，代码会停止其中一个线程。下面是对代码的详细解释：

T = time.nowStamp();：获取当前的时间戳，并将其赋值给变量T。这个时间戳用于后续计算程序已经运行的时间。
创建两个线程对象：var thread1 = new thread(); 和 var thread2 = new thread();。这里创建了两个线程实例，分别命名为thread1和thread2。
启动线程：

thread1.runJsFile('线程1.js', 'worker1');：启动thread1，并运行名为线程1.js的JavaScript文件。同时，为这个线程指定一个名字worker1。
thread2.runJsFile('线程2.js', 'worker2');：启动thread2，并运行名为线程2.js的JavaScript文件。同时，为这个线程指定一个名字worker2。

进入一个无限循环while (true)，在此循环中：

printl("正常运行");：打印字符串"正常运行"到控制台，用于检查程序是否在正常运行。
sleep.millisecond(1000);：让当前线程休眠1000毫秒（即1秒），暂停执行后续代码以避免短时间内频繁打印，提高程序的可读性。
if (time.nowStamp() - T > 10000)：计算当前时间与T所记录的时间之间的差值，判断是否已经过去了10000毫秒（即10秒）。如果是，则执行thread1.stop();，即停止thread1线程。
break;：退出无限循环，结束监控。

// ======================
// 兼容版线程控制示例
// ======================

// 初始化
var T = time.nowStamp(); // 记录系统启动的时间戳
var MAX_WORKERS = 4; // 定义最大工作线程数为4
var TASK_QUEUE = []; // 任务队列，用于存储待执行的任务
var isRunning = true; // 系统运行标志，当为true时，系统持续运行

// 1. 定义工作任务
function createTask(taskId) {
return {
id: taskId, // 任务ID
status: "pending", // 任务状态，初始为"pending"（待执行）
startTime: 0, // 任务开始时间，初始为0
endTime: 0 // 任务结束时间，初始为0
};
}

// 2. 工作线程执行函数
function workerFunction(workerId) {
while (isRunning) { // 当系统正在运行时，工作线程持续寻找任务
var task = TASK_QUEUE.find(t => t.status === "pending");
if (task) { // 找到待执行的任务
task.status = "running"; // 将任务状态更改为"running"（正在执行）
task.startTime = time.nowStamp(); // 记录任务开始时间
printl(`[${workerId}] 开始执行任务 ${task.id}`); // 打印工作线程开始执行任务的信息
try {
// 直接执行截图脚本
load("截图.js"); // 加载并执行"截图.js"脚本，用于执行具体的任务逻辑
task.status = "completed"; // 任务执行成功后，将状态更改为"completed"（已完成）
printl(`[${workerId}] 任务 ${task.id} 完成`); // 打印工作线程完成任务的信息
} catch (e) {
task.status = "failed"; // 如果任务执行过程中发生错误，将状态更改为"failed"（失败）
printl(`[${workerId}] 任务 ${task.id} 失败: ${e}`); // 打印工作线程任务失败的信息及错误原因
} finally {
task.endTime = time.nowStamp(); // 无论任务成功或失败，记录任务结束时间
}
}
sleep.millisecond(100); // 如果没有待执行的任务，工作线程休眠100毫秒后再次检查
}
}

// 3. 初始化线程池
function initThreadPool() {
for (var i = 0; i < MAX_WORKERS; i++) { // 根据MAX_WORKERS的数量创建相应数量的工作线程
var worker = new thread(); // 创建一个新线程
worker.runJsFile("截图.js", "worker-" + (i + 1)); // 让新线程运行"截图.js"脚本，传入线程ID作为参数
}
printl(`已创建 ${MAX_WORKERS} 个工作线程`); // 打印已创建的工作线程数量信息
}

// 4. 状态监控
function monitor() {
while (isRunning) { // 当系统正在运行时，持续监控任务进度
var completed = TASK_QUEUE.filter(t => t.status === "completed").length; // 统计已完成的任务数量
printl(`任务进度: ${completed}/${TASK_QUEUE.length}`); // 打印当前任务进度信息

if (time.nowStamp() - T > 10000) { // 如果系统运行时间超过10秒
isRunning = false; // 将系统运行标志设为false，停止系统运行
printl("监控结束"); // 打印监控结束的信息
break; // 退出循环
}
sleep.millisecond(2000); // 监控线程每2秒检查一次任务进度
}
}

// ======================
// 主程序执行
// ======================

// 添加任务
for (var i = 1; i <= 10; i++) { // 添加10个任务到任务队列
TASK_QUEUE.push(createTask("task-" + i)); // 调用createTask函数创建任务，并将其添加到TASK_QUEUE中
}

// 启动系统
initThreadPool(); // 初始化线程池，启动工作线程

// 启动监控线程
var monitorThread = new thread(); // 创建一个新的线程，用于监控
monitorThread.runJsFile("截图.js", "monitor"); // 让监控线程运行"截图.js"脚本，传入"monitor"作为参数

// 主线程执行监控
monitor(); // 主线程也运行监控函数，监控任务进度

printl("系统运行结束"); // 打印系统运行结束的信息

以下是代码的详细说明：
初始化

var T = time.nowStamp();：记录系统启动的时间戳。
var MAX_WORKERS = 4;：定义最大工作线程数为4。
var TASK_QUEUE = [];：任务队列，用于存储待执行的任务。
var isRunning = true;：系统运行标志，当为true时，系统持续运行。

定义工作任务

function createTask(taskId)：定义一个函数来创建任务对象。

id: taskId：任务ID。
status: "pending"：任务状态，初始为"pending"（待执行）。
startTime: 0：任务开始时间，初始为0。
endTime: 0：任务结束时间，初始为0。

工作线程执行函数

function workerFunction(workerId)：定义一个工作线程的执行函数。

while (isRunning)：当系统正在运行时，工作线程持续寻找任务。
var task = TASK_QUEUE.find(t => t.status === "pending");：从任务队列中找到状态为"pending"的任务。
if (task)：如果找到待执行的任务。

task.status = "running";：将任务状态更改为"running"（正在执行）。
task.startTime = time.nowStamp();：记录任务开始时间。
printl([{task.id});：打印工作线程开始执行任务的信息。
try：尝试执行任务。

load("截图.js");：加载并执行"截图.js"脚本，用于执行具体的任务逻辑。
task.status = "completed";：任务执行成功后，将状态更改为"completed"（已完成）。
printl([{task.id} 完成);：打印工作线程完成任务的信息。

catch (e)：如果任务执行过程中发生错误。

task.status = "failed";：将任务状态更改为"failed"（失败）。
printl([{task.id} 失败: ${e});：打印工作线程任务失败的信息及错误原因。

finally：无论任务成功或失败。

task.endTime = time.nowStamp();：记录任务结束时间。

sleep.millisecond(100);：如果没有待执行的任务，工作线程休眠100毫秒后再次检查。

初始化线程池

function initThreadPool()：定义一个函数来初始化线程池。

for (var i = 0; i < MAX_WORKERS; i++)：根据MAX_WORKERS的数量创建相应数量的工作线程。

var worker = new thread();：创建一个新线程。
worker.runJsFile("截图.js", "worker-" + (i + 1));：让新线程运行"截图.js"脚本，传入线程ID作为参数。

printl(已创建 ${MAX_WORKERS} 个工作线程);：打印已创建的工作线程数量信息。

状态监控

function monitor()：定义一个状态监控函数。

while (isRunning)：当系统正在运行时，持续监控任务进度。

var completed = TASK_QUEUE.filter(t => t.status === "completed").length;：统计已完成的任务数量。
printl(任务进度: {TASK_QUEUE.length});：打印当前任务进度信息。
if (time.nowStamp() - T > 10000)：如果系统运行时间超过10秒。

isRunning = false;：将系统运行标志设为false，停止系统运行。
printl("监控结束");：打印监控结束的信息。
break;：退出循环。

sleep.millisecond(2000);：监控线程每2秒检查一次任务进度。

主程序执行

添加任务：使用for循环添加10个任务到任务队列。
启动系统：调用initThreadPool()函数初始化线程池，启动工作线程。
启动监控线程：创建一个新的线程用于监控，并运行"截图.js"脚本，传入"monitor"作为参数。
主线程执行监控：调用monitor()函数进行监控。