AIWROK软件演示多线程创建暂停恢复

群发软件

	AIWROK软件演示多线程创建暂停恢复 /*    AIWROK多线程综合操作示例    适用环境：安卓Rhino JavaScript引擎（ES5）    功能：综合演示多线程创建、暂停/恢复、优先级控制、许可证同步等核心功能        场景模拟：一个自动化任务系统    - 主监控线程（高优先级）：监控系统状态    - 数据处理线程（中优先级）：处理业务数据    - 日志记录线程（低优先级）：记录操作日志    - 使用许可证确保关键操作的原子性 */ // ==================== 全局配置 ==================== var MIN_PRIORITY = 1;      // 最低优先级 var NORM_PRIORITY = 5;     // 正常优先级 var MAX_PRIORITY = 10;     // 最高优先级 // ==================== 日志悬浮窗初始化 ==================== var logWindow = new floatUI(); var logText = null; function initLogWindow() {     try {         logWindow.loadXML(             '<LinearLayout orientation="vertical" w="match_parent" h="match_parent" gravity="left">' +             '  <TextView id="logText" textColor="#00ff00" background="#000000" textSize="9" layout_width="wrap_content" layout_height="wrap_content" />' +             '</LinearLayout>'         );                  logText = logWindow.findViewById('logText');                  if (logText) {             setTimeout(function() {                 logWindow.setPosition(10, 100);             }, 100);                          logText.setText("AIWROK多线程综合示例\n");         } else {             print.log("日志视图未正确初始化");         }     } catch (e) {         print.log("创建日志悬浮窗失败: " + String(e));     } } // 更新日志显示 function updateLog(content) {     print.log(content);         try {         if (logText) {             var currentTime = new Date().toLocaleTimeString();             var logContent = logText.getText() || "";             var newLogContent = "[" + currentTime + "] " + content + "\n" + logContent;             // 限制日志行数，避免内容过多（增加到100行以填满全屏）             var logLines = newLogContent.split("\n");             if (logLines.length > 100) {                 newLogContent = logLines.slice(0, 100).join("\n");             }             logText.setText(newLogContent);         }     } catch (e) {         print.log("更新日志失败: " + String(e));     } } // ==================== 线程许可证工具 ==================== function ThreadLicense() {     var _isLocked = false;     var _waitingQueue = [];         this.acquire = function(callback) {         if (typeof callback !== 'function') {             return false;         }                  if (!_isLocked) {             _isLocked = true;             try {                 callback(this.release.bind(this));             } catch (e) {                 this.release();                 throw e;             }             return true;         } else {             _waitingQueue.push(callback);             return false;         }     };         this.release = function() {         _isLocked = false;         if (_waitingQueue.length > 0) {             var nextCallback = _waitingQueue.shift();             this.acquire(nextCallback);         }     };         this.isLocked = function() {         return _isLocked;     };         this.getQueueLength = function() {         return _waitingQueue.length;     }; } // 创建全局许可证用于数据库操作 var dbLicense = new ThreadLicense(); // ==================== 可暂停线程类 ==================== function PausableThread(name, priority) {     var _thread = new thread();     var _isPaused = false;     var _isRunning = false;     var _name = name || "未命名线程";     var _priority = priority || NORM_PRIORITY;         this.pause = function() {         _isPaused = true;         updateLog("[" + _name + "] 线程已暂停");     };         this.resume = function() {         if (_isPaused) {             _isPaused = false;             updateLog("[" + _name + "] 线程已恢复");         }     };         this.isPaused = function() {         return _isPaused;     };         this.isAlive = function() {         return _thread.isAlive();     };         this.stop = function() {         _isRunning = false;         _thread.stop();         updateLog("[" + _name + "] 线程已停止");     };         var _checkPause = function() {         while (_isPaused && _isRunning) {             try {                 java.lang.Thread.sleep(100);             } catch (e) {                 updateLog("[" + _name + "] 暂停等待异常: " + String(e));             }         }     };         this.start = function(taskFunction) {         _isRunning = true;         _isPaused = false;                  var threadName = _name;         var priority = _priority;                  _thread.runJsCode(function() {             try {                 // 设置线程优先级                 java.lang.Thread.currentThread().setPriority(priority);                                 var checkPause = _checkPause;                 var isRunning = function() { return _isRunning; };                                 taskFunction(checkPause, isRunning, threadName);             } catch (e) {                 updateLog("[" + threadName + "] 线程执行异常: " + String(e));             }         }, _name);                  updateLog("[" + _name + "] 线程已启动 (优先级:" + priority + ")");     };         this.getName = function() {         return _name;     }; } // ==================== 业务线程定义 ==================== // 1. 主监控线程（高优先级）- 获取百度首页并监控状态 function monitorTask(checkPause, isRunning, threadName) {     updateLog("[" + threadName + "] 开始获取百度首页");     var cycleCount = 0;         while (isRunning() && cycleCount < 5) {         checkPause();         cycleCount++;                  try {             // 使用okHttp.get获取百度首页             var httpObj = new okHttp();             var response = httpObj.get("https://www.baidu.com");             if (response) {                 // 截取前100个字符显示                 var preview = String(response).substring(0, 100);                 updateLog("[" + threadName + "] 第" + cycleCount + "次请求: 成功");                 updateLog("[" + threadName + "] 响应预览: " + preview + "...");             } else {                 updateLog("[" + threadName + "] 第" + cycleCount + "次请求: 失败");             }         } catch (e) {             updateLog("[" + threadName + "] 第" + cycleCount + "次请求异常: " + String(e));         }                  try {             java.lang.Thread.sleep(1500);         } catch (e) {             updateLog("[" + threadName + "] 休眠异常: " + String(e));         }     }         updateLog("[" + threadName + "] 监控任务完成"); } // 2. 数据处理线程（中优先级）- 获取百度首页数据 function dataProcessTask(checkPause, isRunning, threadName) {     updateLog("[" + threadName + "] 开始处理百度数据");     var processedCount = 0;         while (isRunning() && processedCount < 5) {         checkPause();         processedCount++;                  // 使用许可证确保操作的原子性         dbLicense.acquire(function(release) {             updateLog("[" + threadName + "] 获取数据库许可证，处理第" + processedCount + "条数据");                          try {                 // 获取百度首页                 var httpObj = new okHttp();                 var response = httpObj.get("https://www.baidu.com");                 if (response) {                     // 截取前80个字符显示                     var preview = String(response).substring(0, 80);                     updateLog("[" + threadName + "] 第" + processedCount + "条数据获取成功");                     updateLog("[" + threadName + "] 响应: " + preview + "...");                 } else {                     updateLog("[" + threadName + "] 第" + processedCount + "条数据获取失败");                 }             } catch (e) {                 updateLog("[" + threadName + "] 第" + processedCount + "条数据异常: " + String(e));             }                          updateLog("[" + threadName + "] 第" + processedCount + "条数据处理完成");             release();         });                  try {             java.lang.Thread.sleep(1000);         } catch (e) {             updateLog("[" + threadName + "] 休眠异常: " + String(e));         }     }         updateLog("[" + threadName + "] 数据处理完成，共处理" + processedCount + "条"); } // 3. 日志记录线程（低优先级）- 获取百度首页并记录 function logRecordTask(checkPause, isRunning, threadName) {     updateLog("[" + threadName + "] 开始记录百度访问日志");     var logCount = 0;         while (isRunning() && logCount < 10) {         checkPause();         logCount++;                  try {             // 获取百度首页             var httpObj = new okHttp();             var response = httpObj.get("https://www.baidu.com");             if (response) {                 // 截取前60个字符显示                 var preview = String(response).substring(0, 60);                 updateLog("[" + threadName + "] 记录访问 #" + logCount + " - 成功");                 updateLog("[" + threadName + "] 响应: " + preview + "...");             } else {                 updateLog("[" + threadName + "] 记录访问 #" + logCount + " - 失败");             }         } catch (e) {             updateLog("[" + threadName + "] 记录访问 #" + logCount + " 异常");         }                  try {             java.lang.Thread.sleep(800);         } catch (e) {             updateLog("[" + threadName + "] 休眠异常: " + String(e));         }     }         updateLog("[" + threadName + "] 日志记录完成，共记录" + logCount + "条"); } // ==================== 线程管理 ==================== // 创建三个不同优先级的线程 var monitorThread = new PausableThread("监控线程", MAX_PRIORITY); var dataThread = new PausableThread("数据处理线程", NORM_PRIORITY); var logThread = new PausableThread("日志线程", MIN_PRIORITY); // 启动所有线程 function startAllThreads() {     updateLog("========== 启动所有线程 ==========");         monitorThread.start(monitorTask);     sleep.second(秒=0.2);         dataThread.start(dataProcessTask);     sleep.second(秒=0.2);         logThread.start(logRecordTask);         updateLog("所有线程已启动"); } // 暂停所有线程 function pauseAllThreads() {     updateLog("========== 暂停所有线程 ==========");     monitorThread.pause();     dataThread.pause();     logThread.pause(); } // 恢复所有线程 function resumeAllThreads() {     updateLog("========== 恢复所有线程 ==========");     monitorThread.resume();     dataThread.resume();     logThread.resume(); } // 停止所有线程 function stopAllThreads() {     updateLog("========== 停止所有线程 ==========");     monitorThread.stop();     dataThread.stop();     logThread.stop(); } // 监控线程状态 function monitorThreadStatus() {     var isMonitoring = true;         function checkStatus() {         if (!isMonitoring) return;                  try {             var mStatus = monitorThread.isAlive() ? "运行" : "停止";             var dStatus = dataThread.isAlive() ? "运行" : "停止";             var lStatus = logThread.isAlive() ? "运行" : "停止";                          var mPause = monitorThread.isPaused() ? "[暂停]" : "";             var dPause = dataThread.isPaused() ? "[暂停]" : "";             var lPause = logThread.isPaused() ? "[暂停]" : "";                          updateLog("状态 | 监控:" + mStatus + mPause + " | 数据:" + dStatus + dPause + " | 日志:" + lStatus + lPause);                          // 如果所有线程都已结束，停止监控             if (!monitorThread.isAlive() && !dataThread.isAlive() && !logThread.isAlive()) {                 isMonitoring = false;                 updateLog("所有线程已结束");                 return;             }                          // 继续下一次检查             setTimeout(checkStatus, 3000);         } catch (e) {             updateLog("监控线程状态出错: " + String(e));         }     }         // 启动第一次检查     setTimeout(checkStatus, 3000); } // ==================== 自动演示流程 ==================== function autoDemo() {     updateLog("========== 开始自动演示 ==========");     updateLog("演示场景: 多线程并发访问 https://www.baidu.com");     updateLog("线程1(高优先级): GET 百度首页 - 5次");     updateLog("线程2(中优先级): GET 百度首页 - 5次 (带许可证)");     updateLog("线程3(低优先级): GET 百度首页 - 10次");     updateLog("===============================");     updateLog("演示流程:");     updateLog("1. 启动3个不同优先级的线程");     updateLog("2. 3秒后暂停所有线程");     updateLog("3. 5秒后恢复所有线程");     updateLog("4. 8秒后再次暂停");     updateLog("5. 10秒后恢复");     updateLog("6. 15秒后停止所有线程");     updateLog("===============================");         // 启动所有线程     startAllThreads();         // 3秒后暂停     setTimeout(function() {         pauseAllThreads();     }, 3000);         // 5秒后恢复     setTimeout(function() {         resumeAllThreads();     }, 5000);         // 8秒后再次暂停     setTimeout(function() {         pauseAllThreads();     }, 8000);         // 10秒后恢复     setTimeout(function() {         resumeAllThreads();     }, 10000);         // 15秒后停止     setTimeout(function() {         stopAllThreads();     }, 15000); } // ==================== 程序入口 ==================== initLogWindow(); updateLog("AIWROK多线程综合操作示例"); updateLog("版本: 1.0"); updateLog(""); // 延迟2秒后开始自动演示 setTimeout(function() {     autoDemo();     monitorThreadStatus(); }, 2000); 复制代码