gnh1201/welsonjs
1
0
Fork 0
mirror of https://github.com/gnh1201/welsonjs.git synced 2025-05-15 06:01:04 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update task.js

Browse Source
This commit is contained in:
Namhyeon Go 2021-06-23 14:54:47 +09:00 committed by GitHub
parent 4ece56e47e
commit 4382867eb8
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 15 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
lib/task.js
View File

@ -42,11 +42,21 @@ var TaskQueue = function() {
}; };
this.get = function() { this.get = function() {
var task = null; var task = null;
var now = new Date().getTime();
var delta = now;
try { try {
if (this.queue.length > 0) { if (this.queue.length > 0) {
task = this.queue[0]; var k = 0;
this.queue = this.queue.slice(1); for (var i = 0; i < this.queue.length; i++) {
var _delta = now - this.queue[i].when;
if (delta > _delta) {
k = i;
delta = _delta;
}
}
task = this.queue[k];
this.queue = this.queue.splice(k, 1);
} }
} catch(e) { } catch(e) {
console.error("TaskQueue.get: " + e.message); console.error("TaskQueue.get: " + e.message);
@ -56,7 +66,7 @@ var TaskQueue = function() {
}; };
this.next = function() { this.next = function() {
var result = null; var result = null;
try { try {
var task = this.get(); var task = this.get();
@ -66,7 +76,7 @@ var TaskQueue = function() {
} catch (e) { } catch (e) {
console.error("Task exception: " + e.message); console.error("Task exception: " + e.message);
} }
if (task.nextTask != null) { if (task.nextTask != null) {
this.put(task.nextTask); this.put(task.nextTask);
} }