注册 登录
发贴工具
自动发帖软件»群发软件 › 群发软件公告教程 › AIWORK源码分享 › AIWROK软件演示多线程创建暂停恢复
返回列表 发帖
查看: 183|回复: 0
打印 上一主题 下一主题

[24小时收录超级好的网站] AIWROK软件演示多线程创建暂停恢复

[复制链接]

2596

主题

2644

帖子

1万

积分

积分
15752
跳转到指定楼层
楼主
发帖软件 发表于 2026-6-23 06:28:55 | 只看该作者 |只看大图 回帖奖励 |倒序浏览 |阅读模式
AIWROK软件演示多线程创建暂停恢复
AIWROK软件演示多线程创建暂停恢复 群发软件发帖工具

  1. /*
  2.    AIWROK多线程综合操作示例
  3.    适用环境：安卓Rhino JavaScript引擎（ES5）
  4.    功能：综合演示多线程创建、暂停/恢复、优先级控制、许可证同步等核心功能
  5.    
  6.    场景模拟：一个自动化任务系统
  7.    - 主监控线程（高优先级）：监控系统状态
  8.    - 数据处理线程（中优先级）：处理业务数据
  9.    - 日志记录线程（低优先级）：记录操作日志
  10.    - 使用许可证确保关键操作的原子性
  11. */

  13. // ==================== 全局配置 ====================
  14. var MIN_PRIORITY = 1;      // 最低优先级
  15. var NORM_PRIORITY = 5;     // 正常优先级
  16. var MAX_PRIORITY = 10;     // 最高优先级

  18. // ==================== 日志悬浮窗初始化 ====================
  19. var logWindow = new floatUI();
  20. var logText = null;

  22. function initLogWindow() {
  23.     try {
  24.         logWindow.loadXML(
  25.             '<LinearLayout orientation="vertical" w="match_parent" h="match_parent" gravity="left">' +
  26.             '  <TextView id="logText" textColor="#00ff00" background="#000000" textSize="9" layout_width="wrap_content" layout_height="wrap_content" />' +
  27.             '</LinearLayout>'
  28.         );
  29.         
  30.         logText = logWindow.findViewById('logText');
  31.         
  32.         if (logText) {
  33.             setTimeout(function() {
  34.                 logWindow.setPosition(10, 100);
  35.             }, 100);
  36.             
  37.             logText.setText("AIWROK多线程综合示例\n");
  38.         } else {
  39.             print.log("日志视图未正确初始化");
  40.         }
  41.     } catch (e) {
  42.         print.log("创建日志悬浮窗失败: " + String(e));
  43.     }
  44. }

  46. // 更新日志显示
  47. function updateLog(content) {
  48.     print.log(content);
  49.    
  50.     try {
  51.         if (logText) {
  52.             var currentTime = new Date().toLocaleTimeString();
  53.             var logContent = logText.getText() || "";
  54.             var newLogContent = "[" + currentTime + "] " + content + "\n" + logContent;
  55.             // 限制日志行数，避免内容过多（增加到100行以填满全屏）
  56.             var logLines = newLogContent.split("\n");
  57.             if (logLines.length > 100) {
  58.                 newLogContent = logLines.slice(0, 100).join("\n");
  59.             }
  60.             logText.setText(newLogContent);
  61.         }
  62.     } catch (e) {
  63.         print.log("更新日志失败: " + String(e));
  64.     }
  65. }

  67. // ==================== 线程许可证工具 ====================
  68. function ThreadLicense() {
  69.     var _isLocked = false;
  70.     var _waitingQueue = [];
  71.    
  72.     this.acquire = function(callback) {
  73.         if (typeof callback !== 'function') {
  74.             return false;
  75.         }
  76.         
  77.         if (!_isLocked) {
  78.             _isLocked = true;
  79.             try {
  80.                 callback(this.release.bind(this));
  81.             } catch (e) {
  82.                 this.release();
  83.                 throw e;
  84.             }
  85.             return true;
  86.         } else {
  87.             _waitingQueue.push(callback);
  88.             return false;
  89.         }
  90.     };
  91.    
  92.     this.release = function() {
  93.         _isLocked = false;
  94.         if (_waitingQueue.length > 0) {
  95.             var nextCallback = _waitingQueue.shift();
  96.             this.acquire(nextCallback);
  97.         }
  98.     };
  99.    
  100.     this.isLocked = function() {
  101.         return _isLocked;
  102.     };
  103.    
  104.     this.getQueueLength = function() {
  105.         return _waitingQueue.length;
  106.     };
  107. }

  109. // 创建全局许可证用于数据库操作
  110. var dbLicense = new ThreadLicense();

  112. // ==================== 可暂停线程类 ====================
  113. function PausableThread(name, priority) {
  114.     var _thread = new thread();
  115.     var _isPaused = false;
  116.     var _isRunning = false;
  117.     var _name = name || "未命名线程";
  118.     var _priority = priority || NORM_PRIORITY;
  119.    
  120.     this.pause = function() {
  121.         _isPaused = true;
  122.         updateLog("[" + _name + "] 线程已暂停");
  123.     };
  124.    
  125.     this.resume = function() {
  126.         if (_isPaused) {
  127.             _isPaused = false;
  128.             updateLog("[" + _name + "] 线程已恢复");
  129.         }
  130.     };
  131.    
  132.     this.isPaused = function() {
  133.         return _isPaused;
  134.     };
  135.    
  136.     this.isAlive = function() {
  137.         return _thread.isAlive();
  138.     };
  139.    
  140.     this.stop = function() {
  141.         _isRunning = false;
  142.         _thread.stop();
  143.         updateLog("[" + _name + "] 线程已停止");
  144.     };
  145.    
  146.     var _checkPause = function() {
  147.         while (_isPaused && _isRunning) {
  148.             try {
  149.                 java.lang.Thread.sleep(100);
  150.             } catch (e) {
  151.                 updateLog("[" + _name + "] 暂停等待异常: " + String(e));
  152.             }
  153.         }
  154.     };
  155.    
  156.     this.start = function(taskFunction) {
  157.         _isRunning = true;
  158.         _isPaused = false;
  159.         
  160.         var threadName = _name;
  161.         var priority = _priority;
  162.         
  163.         _thread.runJsCode(function() {
  164.             try {
  165.                 // 设置线程优先级
  166.                 java.lang.Thread.currentThread().setPriority(priority);
  167.                
  168.                 var checkPause = _checkPause;
  169.                 var isRunning = function() { return _isRunning; };
  170.                
  171.                 taskFunction(checkPause, isRunning, threadName);
  172.             } catch (e) {
  173.                 updateLog("[" + threadName + "] 线程执行异常: " + String(e));
  174.             }
  175.         }, _name);
  176.         
  177.         updateLog("[" + _name + "] 线程已启动 (优先级:" + priority + ")");
  178.     };
  179.    
  180.     this.getName = function() {
  181.         return _name;
  182.     };
  183. }

  185. // ==================== 业务线程定义 ====================

  187. // 1. 主监控线程（高优先级）- 获取百度首页并监控状态
  188. function monitorTask(checkPause, isRunning, threadName) {
  189.     updateLog("[" + threadName + "] 开始获取百度首页");
  190.     var cycleCount = 0;
  191.    
  192.     while (isRunning() && cycleCount < 5) {
  193.         checkPause();
  194.         cycleCount++;
  195.         
  196.         try {
  197.             // 使用okHttp.get获取百度首页
  198.             var httpObj = new okHttp();
  199.             var response = httpObj.get("https://www.baidu.com");
  200.             if (response) {
  201.                 // 截取前100个字符显示
  202.                 var preview = String(response).substring(0, 100);
  203.                 updateLog("[" + threadName + "] 第" + cycleCount + "次请求: 成功");
  204.                 updateLog("[" + threadName + "] 响应预览: " + preview + "...");
  205.             } else {
  206.                 updateLog("[" + threadName + "] 第" + cycleCount + "次请求: 失败");
  207.             }
  208.         } catch (e) {
  209.             updateLog("[" + threadName + "] 第" + cycleCount + "次请求异常: " + String(e));
  210.         }
  211.         
  212.         try {
  213.             java.lang.Thread.sleep(1500);
  214.         } catch (e) {
  215.             updateLog("[" + threadName + "] 休眠异常: " + String(e));
  216.         }
  217.     }
  218.    
  219.     updateLog("[" + threadName + "] 监控任务完成");
  220. }

  222. // 2. 数据处理线程（中优先级）- 获取百度首页数据
  223. function dataProcessTask(checkPause, isRunning, threadName) {
  224.     updateLog("[" + threadName + "] 开始处理百度数据");
  225.     var processedCount = 0;
  226.    
  227.     while (isRunning() && processedCount < 5) {
  228.         checkPause();
  229.         processedCount++;
  230.         
  231.         // 使用许可证确保操作的原子性
  232.         dbLicense.acquire(function(release) {
  233.             updateLog("[" + threadName + "] 获取数据库许可证，处理第" + processedCount + "条数据");
  234.             
  235.             try {
  236.                 // 获取百度首页
  237.                 var httpObj = new okHttp();
  238.                 var response = httpObj.get("https://www.baidu.com");
  239.                 if (response) {
  240.                     // 截取前80个字符显示
  241.                     var preview = String(response).substring(0, 80);
  242.                     updateLog("[" + threadName + "] 第" + processedCount + "条数据获取成功");
  243.                     updateLog("[" + threadName + "] 响应: " + preview + "...");
  244.                 } else {
  245.                     updateLog("[" + threadName + "] 第" + processedCount + "条数据获取失败");
  246.                 }
  247.             } catch (e) {
  248.                 updateLog("[" + threadName + "] 第" + processedCount + "条数据异常: " + String(e));
  249.             }
  250.             
  251.             updateLog("[" + threadName + "] 第" + processedCount + "条数据处理完成");
  252.             release();
  253.         });
  254.         
  255.         try {
  256.             java.lang.Thread.sleep(1000);
  257.         } catch (e) {
  258.             updateLog("[" + threadName + "] 休眠异常: " + String(e));
  259.         }
  260.     }
  261.    
  262.     updateLog("[" + threadName + "] 数据处理完成，共处理" + processedCount + "条");
  263. }

  265. // 3. 日志记录线程（低优先级）- 获取百度首页并记录
  266. function logRecordTask(checkPause, isRunning, threadName) {
  267.     updateLog("[" + threadName + "] 开始记录百度访问日志");
  268.     var logCount = 0;
  269.    
  270.     while (isRunning() && logCount < 10) {
  271.         checkPause();
  272.         logCount++;
  273.         
  274.         try {
  275.             // 获取百度首页
  276.             var httpObj = new okHttp();
  277.             var response = httpObj.get("https://www.baidu.com");
  278.             if (response) {
  279.                 // 截取前60个字符显示
  280.                 var preview = String(response).substring(0, 60);
  281.                 updateLog("[" + threadName + "] 记录访问 #" + logCount + " - 成功");
  282.                 updateLog("[" + threadName + "] 响应: " + preview + "...");
  283.             } else {
  284.                 updateLog("[" + threadName + "] 记录访问 #" + logCount + " - 失败");
  285.             }
  286.         } catch (e) {
  287.             updateLog("[" + threadName + "] 记录访问 #" + logCount + " 异常");
  288.         }
  289.         
  290.         try {
  291.             java.lang.Thread.sleep(800);
  292.         } catch (e) {
  293.             updateLog("[" + threadName + "] 休眠异常: " + String(e));
  294.         }
  295.     }
  296.    
  297.     updateLog("[" + threadName + "] 日志记录完成，共记录" + logCount + "条");
  298. }

  300. // ==================== 线程管理 ====================
  301. // 创建三个不同优先级的线程
  302. var monitorThread = new PausableThread("监控线程", MAX_PRIORITY);
  303. var dataThread = new PausableThread("数据处理线程", NORM_PRIORITY);
  304. var logThread = new PausableThread("日志线程", MIN_PRIORITY);

  306. // 启动所有线程
  307. function startAllThreads() {
  308.     updateLog("========== 启动所有线程 ==========");
  309.    
  310.     monitorThread.start(monitorTask);
  311.     sleep.second(秒=0.2);
  312.    
  313.     dataThread.start(dataProcessTask);
  314.     sleep.second(秒=0.2);
  315.    
  316.     logThread.start(logRecordTask);
  317.    
  318.     updateLog("所有线程已启动");
  319. }

  321. // 暂停所有线程
  322. function pauseAllThreads() {
  323.     updateLog("========== 暂停所有线程 ==========");
  324.     monitorThread.pause();
  325.     dataThread.pause();
  326.     logThread.pause();
  327. }

  329. // 恢复所有线程
  330. function resumeAllThreads() {
  331.     updateLog("========== 恢复所有线程 ==========");
  332.     monitorThread.resume();
  333.     dataThread.resume();
  334.     logThread.resume();
  335. }

  337. // 停止所有线程
  338. function stopAllThreads() {
  339.     updateLog("========== 停止所有线程 ==========");
  340.     monitorThread.stop();
  341.     dataThread.stop();
  342.     logThread.stop();
  343. }

  345. // 监控线程状态
  346. function monitorThreadStatus() {
  347.     var isMonitoring = true;
  348.    
  349.     function checkStatus() {
  350.         if (!isMonitoring) return;
  351.         
  352.         try {
  353.             var mStatus = monitorThread.isAlive() ? "运行" : "停止";
  354.             var dStatus = dataThread.isAlive() ? "运行" : "停止";
  355.             var lStatus = logThread.isAlive() ? "运行" : "停止";
  356.             
  357.             var mPause = monitorThread.isPaused() ? "[暂停]" : "";
  358.             var dPause = dataThread.isPaused() ? "[暂停]" : "";
  359.             var lPause = logThread.isPaused() ? "[暂停]" : "";
  360.             
  361.             updateLog("状态 | 监控:" + mStatus + mPause + " | 数据:" + dStatus + dPause + " | 日志:" + lStatus + lPause);
  362.             
  363.             // 如果所有线程都已结束，停止监控
  364.             if (!monitorThread.isAlive() && !dataThread.isAlive() && !logThread.isAlive()) {
  365.                 isMonitoring = false;
  366.                 updateLog("所有线程已结束");
  367.                 return;
  368.             }
  369.             
  370.             // 继续下一次检查
  371.             setTimeout(checkStatus, 3000);
  372.         } catch (e) {
  373.             updateLog("监控线程状态出错: " + String(e));
  374.         }
  375.     }
  376.    
  377.     // 启动第一次检查
  378.     setTimeout(checkStatus, 3000);
  379. }

  381. // ==================== 自动演示流程 ====================
  382. function autoDemo() {
  383.     updateLog("========== 开始自动演示 ==========");
  384.     updateLog("演示场景: 多线程并发访问 https://www.baidu.com");
  385.     updateLog("线程1(高优先级): GET 百度首页 - 5次");
  386.     updateLog("线程2(中优先级): GET 百度首页 - 5次 (带许可证)");
  387.     updateLog("线程3(低优先级): GET 百度首页 - 10次");
  388.     updateLog("===============================");
  389.     updateLog("演示流程:");
  390.     updateLog("1. 启动3个不同优先级的线程");
  391.     updateLog("2. 3秒后暂停所有线程");
  392.     updateLog("3. 5秒后恢复所有线程");
  393.     updateLog("4. 8秒后再次暂停");
  394.     updateLog("5. 10秒后恢复");
  395.     updateLog("6. 15秒后停止所有线程");
  396.     updateLog("===============================");
  397.    
  398.     // 启动所有线程
  399.     startAllThreads();
  400.    
  401.     // 3秒后暂停
  402.     setTimeout(function() {
  403.         pauseAllThreads();
  404.     }, 3000);
  405.    
  406.     // 5秒后恢复
  407.     setTimeout(function() {
  408.         resumeAllThreads();
  409.     }, 5000);
  410.    
  411.     // 8秒后再次暂停
  412.     setTimeout(function() {
  413.         pauseAllThreads();
  414.     }, 8000);
  415.    
  416.     // 10秒后恢复
  417.     setTimeout(function() {
  418.         resumeAllThreads();
  419.     }, 10000);
  420.    
  421.     // 15秒后停止
  422.     setTimeout(function() {
  423.         stopAllThreads();
  424.     }, 15000);
  425. }

  427. // ==================== 程序入口 ====================
  428. initLogWindow();
  429. updateLog("AIWROK多线程综合操作示例");
  430. updateLog("版本: 1.0");
  431. updateLog("");

  433. // 延迟2秒后开始自动演示
  434. setTimeout(function() {
  435.     autoDemo();
  436.     monitorThreadStatus();
  437. }, 2000);
复制代码




AIWROK, AIWROK软件
楼主新帖
楼主热帖
untoAIWROK软件定时检查页面状态防止卡死技巧nextIOS苹果脚本TXT文件读写H5日志打印完整示例

相关帖子
回复

使用道具 举报

返回列表 发帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

相关导读了
    采集亚马逊正版群发工具有没有？
    Apr.20旅行X心语今天来说说YYPOST新功能的一个灵活用法，采集亚马逊商品信息，并且获得排名的软件，亚马逊现在越来越多客户做，淘宝的水是越来越清了，以前做电商的客户，现在都转战到外国，最赚钱的要数一些客户往亚马逊里堆了吧，拿我这个YYPOST的客户，最多的是采集，分析排名，刷价格，刷数量，改价，刷访问量等等技术
    企业发展B2B网站有什么东东软件可以发呢
    标题企业发展网B2B软件，现在虽然B2B网站收录不错，可愁的是心急的人们，他们太想一口吃撑胖子了，发帖宣传虽然不能像佛系那样淡定，但也不能像跑火车那般急躁对待，自己内容不收录，完全是自己操作内容问题，可以参考一下别人的内容是怎么弄的，然后自己要试着转变，而且收录这个内容，常常会变化的，不是一种规则就吃到老
    搜房天下房聊软件哪一个好呢
    本帖最后由 发帖软件 于 2019-5-22 16:15 编辑 2搜房天下群发房聊信息软件，开始本来打算做58同城的，但发一个就要一次点触验证码，这就让人没有感觉到存在的价值了吧，都是卖二手房和新房的搜房天下倒是可以发即时聊天信息，也没有发现他这个网站有啥子限制，登陆一个搜房天下账号，然后采集回来分类列表的网址，然后就一
    大家坛有没有好用的群发工具下载呢
    当你的笑容给我礼貌的招呼，大家坛全自动发帖软件，宣传推广是一场持久战，总是有一些人把软件用了一天，或是几个小时，就觉得自己付出太多了，那加进来的粉丝，或是流量，应该是和宣传多少成正比的，其实没有这么便宜的事，就像很多阅读量超过一百万的视频，或是电影，真正会在屏幕打赏的人不会超过三千，真正大额打赏给主
    群发正版软件中国塑料网
    中国塑料网群发软件YYPOST脚本下载地址，这个网站会有一个很奇怪的问题就是你在首页登陆无半个验证码，但在登陆网址登陆就会有一个验证码，所以我们灵活一些，在首页登陆就不用输入验证码了哈。网站秒收录比较高，但发的都是五金和建筑行业，先前有很多人都是发土建工程的大公司操作的，现在这个网站专为那个行业诞生的吧。
    OpenStreetMap网站正版2019年发帖工具下载
    本帖最后由 发帖软件 于 2019-5-21 11:13 编辑 OpenStreetMap网站全自动群发，OpenStreetMapOpenStreetMap（简称OSM，中文是公开地图）是一个网上地图协作计划，目标是创造一个内容自由且能让所有人编辑的世界地图。有的人编辑地图然后等收录，有的人发日志等收录，我们这里也是利用地图日志做为宣传的目标，简单的脚本理
    搜房天下全自动收短信全自动识别验证码注册账号软件
    房天下自动注册机，这个脚本是前几天发房聊的脚本廷伸品种，这个脚本能做到自动注册账号，自动保存账号，自动发房聊的效果，不过今天我们主要说一说怎么注册账号写脚本吧，这个搜房天天下的账号，可以发提问，可以发房聊，发论坛，发博客，还有发个人中心页都是有秒收的效果的，这样就省去了去买号，去乱花钱的效果了吧，而
    企业邮箱安卓端有什么APP软件可以发的呢
    请输入标题企业邮箱安卓发发送邮箱脚本，这个脚本是利用企业邮箱进行群发的，全程是一种模拟手工操作的过程，所以封号是很少的，而且企业邮箱群发到普通QQ邮箱不容易进垃圾箱中的，所以这个脚本也是这样的原理，不过最好是利用一些多开器，登陆多点的QQ邮箱账号会比较流畅一些，然后用软件一个一个的切换APP进行群发邮件会
    头条留评论软件有没有好用的呢？
    今天整一个今日头条留言软件，对于留言YYPOST是优势是比较大的存在，因为他往往专注一些下拉定位的优点，像今日头条这样，还是需要一些特殊下拉定位的，因为他新闻有长有短，有图有视频的，所以综合起来定位是比较难的，如果用POST也不是很轻松可以破解他的加密参数。这个脚本也是有一个不好的地方就是换号会比较麻烦，您电
    单网页生成神器
    最近新技术，网页生成机占领了整个网络的半壁江山，效果很疯狂，虽然不知道能持续多久，作为开发软件的领头者，一直在找收录的方法，一直在努力创新着，一直被人模仿，却从没有被超越过，这个网页生成机，已经出来有一段时间了，一直没有拿出来分享，醉过醉过，它是利用的一些小小收录漏洞整的，您最好用一些老站域名，进行
关闭
本站开发自动发帖软件是目前效果最好的发贴工具，软件可以兼容所有的论坛，进行群发贴子，可以对各大论坛自主录制操作流程，自动识别 验证码，自动注册账号，自动群发贴子，还可以设置成自动抢沙发，是推广宣传的神级软件，软件可以兼容任何IE能顶贴发贴论坛，完全可以 做成论坛发贴软件，生成脚本，对各大论坛程序完美支持的。软件不但发的贴子收录快，而且只用法简单，使用方便，价格便宜，软件客服16 小时在线全程协助，为您的宣传保驾护航。用最少的投资，实现最大的收益，用最简单的方式，完全最复杂的操作。 QQ

Copyright © 2014 ( 京ICP备09078825号 )

Powered by Discuz! X3.2

群发软件发帖工具
快速回复 返回列表 返回顶部
本站自动发贴软件，是现在最流行的做脚本软件，这种发贴工具，不但发贴收录快，而且抢占好的先机，完全自由编辑，实现针对性群发模拟操作，软件可以顶贴，也可以发贴，可以兼容支持Discuz、PHPWind、Dvbbs三大主流论坛，有手机验证码收件，邮件收发的功能，支持验证码识别，注册问题识别，多线程任务，自动上传头像，自动激活注册邮件，兼容防注册插件，本站软件原创正版，更新效率最快的原创软件。 『网络推广软件』『自动发帖软件』『 自动发帖』