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

Update task.js

Browse Source
This commit is contained in:
Namhyeon Go 2021-07-16 20:10:27 +09:00 committed by GitHub
parent 3cc3f8b77b
commit 1e3b0dc47e
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 29 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

43
lib/task.js
View File

@ -17,18 +17,22 @@
*/ */
var Task = function(f, params) { var Task = function(f, params) {
var now = new Date();
this.f = f; this.f = f;
this.params = params; this.params = params;
this.nextTask = null; this.nextTask = null;
this.when = now.getTime(); this.when = 0;
this.delay = 0;
this.setNextTask = function(task) { this.setNextTask = function(task) {
this.nextTask = task; this.nextTask = task;
}; };
this.setWhen = function(when) { this.setWhen = function(when) {
this.when = when; this.when = when;
return this;
};
this.setDelay = function(delay) {
this.delay = delay;
return this;
}; };
}; };
@ -36,14 +40,19 @@ var TaskQueue = function() {
this._task = null; this._task = null;
this._keepalive = true; this._keepalive = true;
this.queue = []; this.queue = [];
this.put = function(task) { this.put = function(task, delay) {
var now = new Date();
try { try {
task.setWhen(now.getTime());
if (typeof(delay) !== "undefined") {
task.setDelay(delay);
}
this._task = task; this._task = task;
this.queue.push(this._task); this.queue.push(task);
} catch(e) { } catch(e) {
console.error("TaskQueue.put exception: " + e.message); console.error("TaskQueue.put exception: " + e.message);
} }
return this; return this;
}; };
this.get = function() { this.get = function() {
@ -53,10 +62,11 @@ var TaskQueue = function() {
try { try {
if (this.queue.length > 0) { if (this.queue.length > 0) {
var delta = this.queue.map(function(task) { var delta = this.queue.map(function(task) {
return task.when - now.getTime(); return task.when + task.delay - now.getTime();
}); });
var i = delta.indexOf(Math.min.apply(Math, delta)); var i = delta.indexOf(Math.min.apply(Math, delta));
if (i > -1) { var d = this.queue[i].when + this.queue[i].delay - now.getTime();
if (i > -1 && d <= 0) {
task = this.queue.splice(i, 1)[0]; task = this.queue.splice(i, 1)[0];
} }
} }
@ -76,12 +86,11 @@ var TaskQueue = function() {
try { try {
result = task.f.apply(null, [task].concat(task.params)); result = task.f.apply(null, [task].concat(task.params));
if (task.nextTask != null) { if (task.nextTask != null) {
this.put(task.nextTask); this.put(task.nextTask, task.nextTask.delay);
} }
} catch (e) { } catch (e) {
console.error("Task exception: " + e.message); console.error("Task exception: " + e.message);
console.error("task.f: " + typeof(task.f)); console.error("task.f: " + typeof(task.f));
//WScript.echo(task.f);
console.error("task.params: " + typeof(task.params)); console.error("task.params: " + typeof(task.params));
} }
} }
@ -91,13 +100,17 @@ var TaskQueue = function() {
return result; return result;
}; };
this.then = function(task) { this.then = function(task, delay) {
try { try {
if (typeof(delay) !== "undefined") {
task.setDelay(delay);
}
this._task.setNextTask(task); this._task.setNextTask(task);
this._task = task; this._task = task;
return this; return this;
} catch(e) { } catch(e) {
console.error("TaskQueue.then: " + e.message); console.error("TaskQueue.then: " + e.message);
console.error(this._task);
} }
}; };
this.run = function() { this.run = function() {
@ -125,10 +138,10 @@ exports.createTask = function(f, params) {
} }
}; };
exports.putTask = function(q, task) { exports.putTask = function(q, task, delay) {
try { try {
if (q instanceof TaskQueue && task instanceof Task) { if (q instanceof TaskQueue && task instanceof Task) {
return q.put(task); return q.put(task, delay);
} }
} catch(e) { } catch(e) {
console.error("putTask exception: " + e.message); console.error("putTask exception: " + e.message);
@ -151,6 +164,6 @@ exports.stop = function(q) {
q.stop(); q.stop();
}; };
exports.VERSIONINFO = "Task Module (task.js) version 0.1"; exports.VERSIONINFO = "Task Module (task.js) version 0.2";
exports.global = global; exports.global = global;
exports.require = require; exports.require = require;