AIWROK线程许可证工具

QQ896757558

AIWROK线程许可证工具

1. // AIWROK软件安卓交流QQ群711841924
   
2. // 苹果内测软件QQ群648461709
   
3. 
   
4. function ThreadLicense() {
   
5.     var _isLocked = false;
   
6.     var _waitingQueue = [];
   
7.    
   
8.     /**
   
9.      * 获取许可证
   
10.      * @param {Function} callback - 获取许可证后的回调函数，接收release作为参数
    
11.      * @returns {boolean} 是否成功获取许可证
    
12.      */
    
13.     this.acquire = function(callback) {
    
14.         if (typeof callback !== 'function') {
    
15.             return false;
    
16.         }
    
17.         
    
18.         if (!_isLocked) {
    
19.             _isLocked = true;
    
20.             // 执行回调，并传入release函数
    
21.             try {
    
22.                 callback(this.release.bind(this));
    
23.             } catch (e) {
    
24.                 // 出错时自动释放许可证
    
25.                 this.release();
    
26.                 throw e;
    
27.             }
    
28.             return true;
    
29.         } else {
    
30.             // 添加到等待队列
    
31.             _waitingQueue.push(callback);
    
32.             return false;
    
33.         }
    
34.     };
    
35.    
    
36.     /**
    
37.      * 释放许可证
    
38.      */
    
39.     this.release = function() {
    
40.         _isLocked = false;
    
41.         
    
42.         // 处理下一个等待请求
    
43.         if (_waitingQueue.length > 0) {
    
44.             var nextCallback = _waitingQueue.shift();
    
45.             this.acquire(nextCallback);
    
46.         }
    
47.     };
    
48.    
    
49.     /**
    
50.      * 检查是否被锁定
    
51.      * @returns {boolean} 是否已锁定
    
52.      */
    
53.     this.isLocked = function() {
    
54.         return _isLocked;
    
55.     };
    
56.    
    
57.     /**
    
58.      * 获取等待队列长度
    
59.      * @returns {number} 等待队列长度
    
60.      */
    
61.     this.getQueueLength = function() {
    
62.         return _waitingQueue.length;
    
63.     };
    
64. }
    
65. 
    
66. // 全局许可证实例
    
67. var globalLicense = new ThreadLicense();
    
68. 
    
69. /**
    
70. * 创建许可证实例的便捷方法
    
71. * @returns {ThreadLicense} 新的许可证实例
    
72. */
    
73. function createThreadLicense() {
    
74.     return new ThreadLicense();
    
75. }
    
76. 
    
77. // 简单的延时函数
    
78. function delay(ms, callback) {
    
79.     if (typeof java !== 'undefined' && java.lang.Thread && java.lang.Thread.sleep) {
    
80.         // Rhino环境
    
81.         try {
    
82.             java.lang.Thread.sleep(ms);
    
83.             if (typeof callback === 'function') {
    
84.                 callback();
    
85.             }
    
86.         } catch (e) {}
    
87.     } else {
    
88.         // 标准环境
    
89.         setTimeout(callback, ms);
    
90.     }
    
91. }
    
92. 
    
93. // 简单的打印函数
    
94. function safePrintl(msg) {
    
95.     if (typeof printl === 'function') {
    
96.         printl(msg);
    
97.     } else if (typeof console !== 'undefined' && typeof console.log === 'function') {
    
98.         console.log(msg);
    
99.     }
    
100. }
     
101. 
     
102. // 简单示例
     
103. function licenseExample() {
     
104.     safePrintl("线程许可证工具 - 简单示例");
     
105.    
     
106.     var license = new ThreadLicense();
     
107.    
     
108.     // 任务1
     
109.     license.acquire(function(release) {
     
110.         safePrintl("任务1获取到许可证");
     
111.         
     
112.         // 模拟耗时操作
     
113.         delay(2000, function() {
     
114.             safePrintl("任务1完成，释放许可证");
     
115.             release();
     
116.         });
     
117.     });
     
118.    
     
119.     // 任务2会等待任务1完成
     
120.     license.acquire(function(release) {
     
121.         safePrintl("任务2获取到许可证");
     
122.         
     
123.         // 模拟耗时操作
     
124.         delay(1000, function() {
     
125.             safePrintl("任务2完成，释放许可证");
     
126.             release();
     
127.         });
     
128.     });
     
129. }
     
130. 
     
131. // 执行示例
     
132. licenseExample();

复制代码