线程全局变量H5可视化控制台

QQ896757558

线程全局变量H5可视化控制台

1. //用多线程异步子任务运行一个定时
   
2. // AIWROK 多线程实时日志监控系统
   
3. var threads = {};
   
4. var threadStatus = {
   
5.     countdown: 'running',
   
6.     randomLetter: 'running',
   
7.     randomTime: 'running',
   
8.     randomNumber: 'running'
   
9. };
   
10. 
    
11. // 辅助函数：将英文状态转换为中文
    
12. function getStatusText(status) {
    
13.     if(status === 'running') return '正在运行';
    
14.     if(status === 'stopping') return '正在停止';
    
15.     if(status === 'stopped') return '已停止';
    
16.     return status;
    
17. }
    
18. 
    
19. // 日志输出函数 - 同时输出到控制台和H5界面
    
20. function logToH5(message, level) {
    
21.     // 输出到控制台
    
22.     console.log(message);
    
23.    
    
24.     // 输出到H5界面（如果LogManagerH5可用）
    
25.     if(typeof LogManagerH5 !== 'undefined' && LogManagerH5.info) {
    
26.         try {
    
27.             switch(level) {
    
28.                 case 'success':
    
29.                     LogManagerH5.success(message);
    
30.                     break;
    
31.                 case 'warn':
    
32.                     LogManagerH5.warn(message);
    
33.                     break;
    
34.                 case 'error':
    
35.                     LogManagerH5.error(message);
    
36.                     break;
    
37.                 case 'gold':
    
38.                     LogManagerH5.gold(message);
    
39.                     break;
    
40.                 default:
    
41.                     LogManagerH5.info(message);
    
42.             }
    
43.         } catch(e) {
    
44.             // 如果H5日志失败，至少控制台有输出
    
45.         }
    
46.     }
    
47. }
    
48. 
    
49. // 线程1: 倒计时线程 (每10分钟倒计时)
    
50. threads.countdown = new thread().runJsCode(function fun(){
    
51.     logToH5("[倒计时线程] 启动 - 开始10分钟倒计时", 'info');
    
52.     var startTime = Date.now();
    
53.     while(threadStatus.countdown === 'running') {
    
54.         var elapsed = Math.floor((Date.now() - startTime) / 1000);
    
55.         var remaining = 600 - elapsed; // 10分钟 = 600秒
    
56.         if(remaining <= 0) {
    
57.             logToH5("[倒计时线程] 倒计时结束!", 'success');
    
58.             break;
    
59.         }
    
60.         logToH5("[倒计时线程] 剩余时间: " + remaining + " 秒", 'info');
    
61.         sleep.second(1);
    
62.     }
    
63.     threadStatus.countdown = 'stopped';
    
64.     logToH5("[倒计时线程] 已停止", 'warn');
    
65. }, "-倒计时线程")
    
66. 
    
67. // 线程2: 随机字母生成线程
    
68. threads.randomLetter = new thread().runJsCode(function fun(){
    
69.     logToH5("[随机字母线程] 启动", 'info');
    
70.     while(threadStatus.randomLetter === 'running') {
    
71.         var letters = 'ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz';
    
72.         var randomIndex = Math.floor(Math.random() * letters.length);
    
73.         var randomLetter = letters.charAt(randomIndex);
    
74.         logToH5("[随机字母线程] 生成随机字母: " + randomLetter, 'gold');
    
75.         sleep.second(1);
    
76.     }
    
77.     threadStatus.randomLetter = 'stopped';
    
78.     logToH5("[随机字母线程] 已停止", 'warn');
    
79. }, "-随机字母线程")
    
80. 
    
81. // 线程3: 随机时间段显示线程
    
82. threads.randomTime = new thread().runJsCode(function fun(){
    
83.     logToH5("[随机时间线程] 启动", 'info');
    
84.     while(threadStatus.randomTime === 'running') {
    
85.         var hours = Math.floor(Math.random() * 24);
    
86.         var minutes = Math.floor(Math.random() * 60);
    
87.         var seconds = Math.floor(Math.random() * 60);
    
88.         var timeStr = String(hours).padStart(2, '0') + ':' +
    
89.                       String(minutes).padStart(2, '0') + ':' +
    
90.                       String(seconds).padStart(2, '0');
    
91.         logToH5("[随机时间线程] 随机时间: " + timeStr, 'info');
    
92.         sleep.second(1);
    
93.     }
    
94.     threadStatus.randomTime = 'stopped';
    
95.     logToH5("[随机时间线程] 已停止", 'warn');
    
96. }, "-随机时间线程")
    
97. 
    
98. // 线程4: 随机数字生成线程
    
99. threads.randomNumber = new thread().runJsCode(function fun(){
    
100.     logToH5("[随机数字线程] 启动", 'info');
     
101.     while(threadStatus.randomNumber === 'running') {
     
102.         var randomNumber = Math.floor(Math.random() * 1000); // 0-999之间的随机数
     
103.         logToH5("[随机数字线程] 生成随机数字: " + randomNumber, 'success');
     
104.         sleep.second(1);
     
105.     }
     
106.     threadStatus.randomNumber = 'stopped';
     
107.     logToH5("[随机数字线程] 已停止", 'warn');
     
108. }, "-随机数字线程")
     
109. 
     
110. // 线程5: 监控线程 - 获取其他线程状态并在10秒后停止所有线程
     
111. threads.monitor = new thread().runJsCode(function fun(){
     
112.     logToH5("[监控线程] 启动 - 将监控其他线程状态", 'info');
     
113.     var startTime = Date.now();
     
114.     var elapsedSeconds = 0;
     
115.    
     
116.     // 辅助函数：将英文状态转换为中文
     
117.     function getStatusText(status) {
     
118.         if(status === 'running') return '正在运行';
     
119.         if(status === 'stopping') return '正在停止';
     
120.         if(status === 'stopped') return '已停止';
     
121.         return status;
     
122.     }
     
123.    
     
124.     // 监控10秒钟
     
125.     while(elapsedSeconds < 10) {
     
126.         logToH5("[监控线程] 当前各线程状态 (已运行 " + elapsedSeconds + " 秒):", 'info');
     
127.         logToH5("  - 倒计时线程: " + getStatusText(threadStatus.countdown), 'info');
     
128.         logToH5("  - 随机字母线程: " + getStatusText(threadStatus.randomLetter), 'info');
     
129.         logToH5("  - 随机时间线程: " + getStatusText(threadStatus.randomTime), 'info');
     
130.         logToH5("  - 随机数字线程: " + getStatusText(threadStatus.randomNumber), 'info');
     
131.         
     
132.         sleep.second(1); // 使用second代替millisecond
     
133.         elapsedSeconds++;
     
134.     }
     
135.    
     
136.     logToH5("[监控线程] 10秒已到，正在停止所有线程...", 'warn');
     
137.    
     
138.     // 更新状态标记
     
139.     threadStatus.countdown = 'stopping';
     
140.     threadStatus.randomLetter = 'stopping';
     
141.     threadStatus.randomTime = 'stopping';
     
142.     threadStatus.randomNumber = 'stopping';
     
143.    
     
144.     // 等待一小段时间让其他线程检测到状态变化并自行停止
     
145.     sleep.second(1);
     
146.    
     
147.     // 强制停止所有工作线程
     
148.     try {
     
149.         if(threads.countdown && threads.countdown.isAlive()) {
     
150.             threads.countdown.interrupt();
     
151.             logToH5("[监控线程] 已中断倒计时线程", 'success');
     
152.         }
     
153.     } catch(e) {
     
154.         logToH5("[监控线程] 停止倒计时线程时出错: " + e.message, 'error');
     
155.     }
     
156.    
     
157.     try {
     
158.         if(threads.randomLetter && threads.randomLetter.isAlive()) {
     
159.             threads.randomLetter.interrupt();
     
160.             logToH5("[监控线程] 已中断随机字母线程", 'success');
     
161.         }
     
162.     } catch(e) {
     
163.         logToH5("[监控线程] 停止随机字母线程时出错: " + e.message, 'error');
     
164.     }
     
165.    
     
166.     try {
     
167.         if(threads.randomTime && threads.randomTime.isAlive()) {
     
168.             threads.randomTime.interrupt();
     
169.             logToH5("[监控线程] 已中断随机时间线程", 'success');
     
170.         }
     
171.     } catch(e) {
     
172.         logToH5("[监控线程] 停止随机时间线程时出错: " + e.message, 'error');
     
173.     }
     
174.    
     
175.     try {
     
176.         if(threads.randomNumber && threads.randomNumber.isAlive()) {
     
177.             threads.randomNumber.interrupt();
     
178.             logToH5("[监控线程] 已中断随机数字线程", 'success');
     
179.         }
     
180.     } catch(e) {
     
181.         logToH5("[监控线程] 停止随机数字线程时出错: " + e.message, 'error');
     
182.     }
     
183.    
     
184.     logToH5("[监控线程] 所有线程已停止，脚本即将结束", 'success');
     
185.    
     
186.     // 最后停止所有脚本
     
187.     stopAll();
     
188. }, "-监控线程")
     
189. 
     
190. logToH5("所有线程已启动，监控线程将在10秒后停止所有其他线程", 'success');

复制代码